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 |
IgniteCondition.await()
Causes the current thread to wait until it is signalled or
interrupted.
|
boolean |
IgniteCondition.await(long time,
TimeUnit unit)
Causes the current thread to wait until it is signalled or interrupted,
or the specified waiting time elapses.
|
long |
IgniteCondition.awaitNanos(long nanosTimeout)
Causes the current thread to wait until it is signalled or interrupted,
or the specified waiting time elapses.
|
boolean |
IgniteCondition.awaitUntil(Date deadline)
Causes the current thread to wait until it is signalled or interrupted,
or the specified deadline elapses.
|
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.
|
void |
IgniteLock.lockInterruptibly()
Acquires the lock unless the current thread is
interrupted.
|
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.
|
boolean |
IgniteLock.tryLock(long timeout,
TimeUnit unit)
Acquires the lock if it is not held by another thread within the given
waiting time and the current thread has not been
interrupted.
|
void |
IgniteLock.unlock()
Releases the lock.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.16.0 Release Date : December 15 2023