| Modifier and Type | Method and Description |
|---|---|
IgniteFuture<?> |
IgniteDataStreamer.addData(Collection<? extends Map.Entry<K,V>> entries)
Adds data for streaming on remote node.
|
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.
|
IgniteFuture<?> |
IgniteDataStreamer.addData(Map<K,V> entries)
Adds data for streaming on remote node.
|
<R> IgniteFuture<R> |
IgniteScheduler.callLocal(Callable<R> c)
Executes given callable on internal system thread pool asynchronously.
|
IgniteFuture<?> |
IgniteCluster.clientReconnectFuture()
If local client node disconnected from cluster returns future
that will be completed when client reconnected.
|
IgniteFuture<?> |
IgniteDataStreamer.future()
Gets future for this streaming process.
|
IgniteFuture<?> |
IgniteCache.rebalance()
This cache node to re-balance its partitions.
|
IgniteFuture<?> |
IgniteClientDisconnectedException.reconnectFuture() |
IgniteFuture<?> |
IgniteDataStreamer.removeData(K key)
Adds key for removal on remote node.
|
IgniteFuture<?> |
IgniteScheduler.runLocal(Runnable r)
Executes given closure on internal system thread pool asynchronously.
|
| Constructor and Description |
|---|
IgniteClientDisconnectedException(IgniteFuture<?> reconnectFut,
String msg) |
IgniteClientDisconnectedException(IgniteFuture<?> reconnectFut,
String msg,
Throwable cause) |
| Modifier and Type | Method and Description |
|---|---|
IgniteFuture<?> |
ClusterTopologyException.retryReadyFuture() |
| Modifier and Type | Method and Description |
|---|---|
void |
ClusterTopologyException.retryReadyFuture(IgniteFuture<?> readyFut) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
ComputeTaskFuture<R>
This class defines a handler for asynchronous task execution.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteFuture<?> |
ComputeTaskSession.mapFuture()
Gets future that will be completed when task "map" step has completed
(which means that
ComputeTask.map(List, Object) method has finished). |
| Modifier and Type | Field and Description |
|---|---|
protected ThreadLocal<IgniteFuture<?>> |
AsyncSupportAdapter.curFut
Future for previous asynchronous operation.
|
| Modifier and Type | Method and Description |
|---|---|
<R> IgniteFuture<R> |
IgniteSchedulerImpl.callLocal(Callable<R> c)
Executes given callable on internal system thread pool asynchronously.
|
protected <R> IgniteFuture<R> |
IgniteComputeImpl.createFuture(IgniteInternalFuture<R> fut) |
protected <R> IgniteFuture<R> |
AsyncSupportAdapter.createFuture(IgniteInternalFuture<R> fut) |
<R> IgniteFuture<R> |
AsyncSupportAdapter.future()
Gets and resets future for previous asynchronous operation.
|
<R> IgniteFuture<R> |
AsyncSupportAdapter.future(boolean reset)
Gets and optionally resets future for previous asynchronous operation.
|
IgniteFuture<?> |
GridJobSessionImpl.mapFuture()
Gets future that will be completed when task "map" step has completed
(which means that
ComputeTask.map(List, Object) method has finished). |
IgniteFuture<?> |
GridTaskSessionImpl.mapFuture()
Gets future that will be completed when task "map" step has completed
(which means that
ComputeTask.map(List, Object) method has finished). |
IgniteFuture<?> |
IgniteClientDisconnectedCheckedException.reconnectFuture() |
IgniteFuture<?> |
IgniteSchedulerImpl.runLocal(Runnable r)
Executes given closure on internal system thread pool asynchronously.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridComponent.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
void |
GridPluginComponent.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
| Constructor and Description |
|---|
IgniteClientDisconnectedCheckedException(IgniteFuture<?> reconnectFut,
String msg) |
| Modifier and Type | Method and Description |
|---|---|
IgniteFuture<?> |
IgniteClusterAsyncImpl.clientReconnectFuture()
If local client node disconnected from cluster returns future
that will be completed when client reconnected.
|
IgniteFuture<?> |
IgniteClusterImpl.clientReconnectFuture()
If local client node disconnected from cluster returns future
that will be completed when client reconnected.
|
<R> IgniteFuture<R> |
IgniteClusterImpl.future()
Gets and resets future for previous asynchronous operation.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteClusterImpl.clientReconnectFuture(IgniteFuture<?> reconnecFut) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridManagerAdapter.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDeploymentManager.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridProcessorAdapter.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteCacheFutureImpl<V>
Implementation of public API future for cache.
|
| Modifier and Type | Method and Description |
|---|---|
<T> IgniteFuture<T> |
IgniteCacheFutureImpl.chain(IgniteClosure<? super IgniteFuture<V>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
IgniteFuture<?> |
IgniteCacheProxy.rebalance()
This cache node to re-balance its partitions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheMvccManager.onDisconnected(IgniteFuture reconnectFut) |
void |
GridCacheAffinityManager.onDisconnected(IgniteFuture reconnectFut) |
void |
GridCacheProcessor.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
void |
GridCacheSharedManager.onDisconnected(IgniteFuture<?> reconnectFut) |
void |
CacheOsConflictResolutionManager.onDisconnected(IgniteFuture<?> reconnectFut) |
void |
GridCacheSharedManagerAdapter.onDisconnected(IgniteFuture<?> reconnectFut) |
void |
GridCacheManagerAdapter.onDisconnected(IgniteFuture<?> reconnectFut) |
void |
GridCacheManager.onDisconnected(IgniteFuture<?> reconnectFut) |
void |
GridCacheGateway.onDisconnected(IgniteFuture<?> reconnectFut) |
| Modifier and Type | Method and Description |
|---|---|
<T> IgniteFuture<T> |
IgniteCacheFutureImpl.chain(IgniteClosure<? super IgniteFuture<V>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheTxFinishSync.onDisconnected(IgniteFuture<?> reconnectFut) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsCacheDrManager.onDisconnected(IgniteFuture reconnectFut) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDistributedQueryManager.onDisconnected(IgniteFuture<?> reconnectFut) |
| Modifier and Type | Method and Description |
|---|---|
<R> IgniteFuture<R> |
TransactionProxyImpl.future()
Gets and resets future for previous asynchronous operation.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxManager.onDisconnected(IgniteFuture reconnectFut) |
| Modifier and Type | Method and Description |
|---|---|
IgniteFuture<?> |
ClusterProcessor.clientReconnectFuture() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridContinuousProcessor.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteFuture<?> |
DataStreamerImpl.addData(Collection<? extends Map.Entry<K,V>> entries)
Adds data for streaming on remote node.
|
IgniteFuture<?> |
DataStreamerImpl.addData(K key,
V val)
Adds data for streaming on remote node.
|
IgniteFuture<?> |
DataStreamerImpl.addData(Map.Entry<K,V> entry)
Adds data for streaming on remote node.
|
IgniteFuture<?> |
DataStreamerImpl.addData(Map<K,V> entries)
Adds data for streaming on remote node.
|
IgniteFuture<?> |
DataStreamerImpl.addDataInternal(Collection<? extends DataStreamerEntry> entries) |
IgniteFuture<?> |
DataStreamerImpl.addDataInternal(KeyCacheObject key,
CacheObject val) |
IgniteFuture<?> |
DataStreamerImpl.future()
Gets future for this streaming process.
|
IgniteFuture<?> |
DataStreamerImpl.removeData(K key)
Adds key for removal on remote node.
|
IgniteFuture<?> |
DataStreamerImpl.removeDataInternal(KeyCacheObject key) |
| Modifier and Type | Method and Description |
|---|---|
void |
DataStreamProcessor.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
void |
DataStreamerImpl.onDisconnected(IgniteFuture<?> reconnectFut) |
| Modifier and Type | Method and Description |
|---|---|
<R> IgniteFuture<R> |
IgfsImpl.future()
Gets and resets future for previous asynchronous operation.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformProcessorImpl.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
protected PlatformListenable |
PlatformAbstractTarget.readAndListenFuture(BinaryRawReader reader,
IgniteFuture fut)
Reads future information and listens.
|
protected PlatformListenable |
PlatformAbstractTarget.readAndListenFuture(BinaryRawReader reader,
IgniteFuture fut,
PlatformFutureUtils.Writer writer)
Reads future information and listens.
|
| Modifier and Type | Method and Description |
|---|---|
static PlatformListenable |
PlatformFutureUtils.getListenable(IgniteFuture fut)
Gets the listenable.
|
static PlatformListenable |
PlatformFutureUtils.listen(PlatformContext ctx,
IgniteFuture fut,
long futPtr,
int typ,
PlatformFutureUtils.Writer writer,
PlatformTarget target)
Listen future.
|
static PlatformListenable |
PlatformFutureUtils.listen(PlatformContext ctx,
IgniteFuture fut,
long futPtr,
int typ,
PlatformTarget target)
Listen future.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridQueryProcessor.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
void |
GridQueryIndexing.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridServiceProcessor.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridTaskProcessor.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteFinishedFutureImpl<V> |
class |
IgniteFutureImpl<V>
Implementation of public API future.
|
| Modifier and Type | Method and Description |
|---|---|
<T> IgniteFuture<T> |
IgniteFutureImpl.chain(IgniteClosure<? super IgniteFuture<V>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
| Modifier and Type | Method and Description |
|---|---|
<T> IgniteFuture<T> |
IgniteFutureImpl.chain(IgniteClosure<? super IgniteFuture<V>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
protected <T> IgniteInternalFuture<T> |
IgniteFutureImpl.chainInternal(IgniteClosure<? super IgniteFuture<V>,T> doneCb) |
void |
IgniteFutureImpl.listen(IgniteInClosure<? super IgniteFuture<V>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
X.waitAll(Iterable<IgniteFuture<?>> futs)
Synchronously waits for all futures in the collection.
|
| Modifier and Type | Method and Description |
|---|---|
<T> IgniteFuture<T> |
IgniteFuture.chain(IgniteClosure<? super IgniteFuture<V>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
<R> IgniteFuture<R> |
IgniteAsyncSupport.future()
Gets and resets future for previous asynchronous operation.
|
| Modifier and Type | Method and Description |
|---|---|
<T> IgniteFuture<T> |
IgniteFuture.chain(IgniteClosure<? super IgniteFuture<V>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
void |
IgniteFuture.listen(IgniteInClosure<? super IgniteFuture<V>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
SchedulerFuture<R>
Future for cron-based scheduled execution.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteSpi.onClientDisconnected(IgniteFuture<?> reconnectFut)
Client node disconnected callback.
|
void |
IgniteSpiAdapter.onClientDisconnected(IgniteFuture<?> reconnectFut)
Client node disconnected callback.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TcpCommunicationSpi.onClientDisconnected(IgniteFuture<?> reconnectFut)
Client node disconnected callback.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.9.0 Release Date : March 2 2017