| Package | Description |
|---|---|
| org.gridgain.grid.dataload |
Contains Data loader API.
|
| org.gridgain.grid.kernal.processors.cache.query | |
| org.gridgain.grid.kernal.processors.clock | |
| org.gridgain.grid.kernal.processors.dataload |
Data loader processor.
|
| org.gridgain.grid.util |
System-wide utility routine and helper classes.
|
| org.gridgain.grid.util.worker |
Common utility classes for threads.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<?> |
GridDataLoader.addData(K key,
V val)
Adds data for loading on remote node.
|
GridFuture<?> |
GridDataLoader.addData(Map.Entry<K,V> entry)
Adds data for loading on remote node.
|
void |
GridDataLoader.close()
Closes data loader.
|
void |
GridDataLoader.close(boolean cancel)
Loads any remaining data and closes this loader.
|
void |
GridDataLoader.flush()
Loads any remaining data, but doesn't close the loader.
|
GridFuture<?> |
GridDataLoader.removeData(K key)
Adds key for removal on remote node.
|
void |
GridDataLoader.tryFlush()
Makes an attempt to load remaining data.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridCacheDistributedQueryFuture.loadAllPages()
Loads all left pages.
|
protected abstract void |
GridCacheQueryFutureAdapter.loadAllPages()
Loads all left pages.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridClockDeltaSnapshot.awaitReady(long timeout)
Awaits either until snapshot is ready or timeout elapses.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDataLoaderImpl.tryFlush()
Flushes every internal buffer if buffer was flushed before passed in
threshold.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
GridUtils.acquire(Semaphore sem)
Acquires a permit from provided semaphore.
|
boolean |
GridAtomicInitializer.await()
Await for completion.
|
static void |
GridUtils.await(Condition cond)
Awaits for condition.
|
static boolean |
GridUtils.await(Condition cond,
long time,
TimeUnit unit)
Awaits for condition.
|
static void |
GridUtils.await(CountDownLatch latch)
Awaits for the latch.
|
static boolean |
GridUtils.await(CountDownLatch latch,
long timeout,
TimeUnit unit)
Awaits for the latch.
|
static void |
GridUtils.join(GridWorker w)
Joins worker.
|
static void |
GridUtils.join(Thread t)
Joins thread.
|
static void |
GridUtils.sleep(long ms)
Sleeps for given number of milliseconds.
|
static void |
GridUtils.wait(Object mux)
Converts
InterruptedException to GridException. |
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
GridWorker.body()
The implementation should provide the execution body for this runnable.
|
Copyright © 2014. All rights reserved.