| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteSemaphore.acquire()
Acquires a permit from this semaphore, blocking until one is available, or the thread is interrupted.
|
void |
IgniteSemaphore.acquire(int permits)
Acquires the given number of permits from this semaphore, blocking until all are available, or the thread is
interrupted.
|
IgniteFuture<?> |
IgniteDataStreamer.addData(K key,
V val)
Adds data for streaming on remote node.
|
IgniteFuture<?> |
IgniteDataStreamer.addData(Map.Entry<K,V> entry)
Adds data for streaming on remote node.
|
void |
IgniteDataStreamer.close()
Closes data streamer.
|
void |
IgniteDataStreamer.close(boolean cancel)
Streams any remaining data and closes this streamer.
|
void |
IgniteDataStreamer.flush()
Streams any remaining data, but doesn't close the streamer.
|
IgniteFuture<?> |
IgniteDataStreamer.removeData(K key)
Adds key for removal on remote node.
|
boolean |
IgniteSemaphore.tryAcquire(int permits,
long timeout,
TimeUnit unit)
Acquires the given number of permits from this semaphore, if all become available within the given waiting time
and the current thread has not been interrupted.
|
boolean |
IgniteSemaphore.tryAcquire(long timeout,
TimeUnit unit)
Acquires a permit from this semaphore, if one becomes available within the given waiting time and the current
thread has not been interrupted.
|
void |
IgniteDataStreamer.tryFlush()
Makes an attempt to stream remaining data.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016