Uses of Interface
org.apache.ignite.lang.IgniteFuture
-
-
Uses of IgniteFuture in org.apache.ignite
Methods in org.apache.ignite that return IgniteFuture Modifier and Type Method Description <T> IgniteFuture<T>IgniteSemaphore. acquireAndExecute(IgniteCallable<T> callable, int numPermits)Acquires the given semaphore, executes the given callable and schedules the release of permits asynchronouslyIgniteFuture<?>IgniteDataStreamer. addData(Collection<? extends Map.Entry<K,V>> entries)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.IgniteFuture<?>IgniteDataStreamer. addData(K key, V val)Adds data for streaming on remote node.<R> IgniteFuture<R>IgniteCompute. affinityCallAsync(@NotNull Collection<String> cacheNames, int partId, IgniteCallable<R> job)Executes given job asynchronously on the node where partition is located (the partition is primary on the node) The data of the partition will not be migrated from the target node while the job is executed.<R> IgniteFuture<R>IgniteCompute. affinityCallAsync(@NotNull Collection<String> cacheNames, Object affKey, IgniteCallable<R> job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).<R> IgniteFuture<R>IgniteCompute. affinityCallAsync(String cacheName, Object affKey, IgniteCallable<R> job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).IgniteFuture<Void>IgniteCompute. affinityRunAsync(@NotNull Collection<String> cacheNames, int partId, IgniteRunnable job)Executes given job asynchronously on the node where partition is located (the partition is primary on the node) The data of the partition will not be migrated from the target node while the job is executed.IgniteFuture<Void>IgniteCompute. affinityRunAsync(@NotNull Collection<String> cacheNames, Object affKey, IgniteRunnable job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).IgniteFuture<Void>IgniteCompute. affinityRunAsync(String cacheName, Object affKey, IgniteRunnable job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).<T,R>
IgniteFuture<Collection<R>>IgniteCompute. applyAsync(IgniteClosure<T,R> job, Collection<? extends T> args)Executes provided closure job asynchronously on nodes within the underlying cluster group.<R,T>
IgniteFuture<R>IgniteCompute. applyAsync(IgniteClosure<T,R> job, T arg)Executes provided closure job asynchronously on a node within the underlying cluster group.<R1,R2,T>
IgniteFuture<R2>IgniteCompute. applyAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc)Executes provided closure job asynchronously on nodes within the underlying cluster group.<R> IgniteFuture<Collection<R>>IgniteCompute. broadcastAsync(IgniteCallable<R> job)Broadcasts given job asynchronously to all nodes in cluster group.<R,T>
IgniteFuture<Collection<R>>IgniteCompute. broadcastAsync(IgniteClosure<T,R> job, T arg)Broadcasts given closure job asynchronously with passed in argument to all nodes in the cluster group.IgniteFuture<Void>IgniteCompute. broadcastAsync(IgniteRunnable job)Broadcasts given job asynchronously to all nodes in the cluster group.<R> IgniteFuture<Collection<R>>IgniteCompute. callAsync(Collection<? extends IgniteCallable<R>> jobs)Executes collection of jobs asynchronously on nodes within the underlying cluster group.<R1,R2>
IgniteFuture<R2>IgniteCompute. callAsync(Collection<? extends IgniteCallable<R1>> jobs, IgniteReducer<R1,R2> rdc)Executes collection of jobs asynchronously on nodes within the underlying cluster group.<R> IgniteFuture<R>IgniteCompute. callAsync(IgniteCallable<R> job)Executes provided job asynchronously on a node within the underlying cluster group.<R> IgniteFuture<R>IgniteScheduler. callLocal(@NotNull Callable<R> c)Executes given callable on internal system thread pool asynchronously.IgniteFuture<Void>IgniteServices. cancelAllAsync()Asynchronously cancels all deployed services.IgniteFuture<Void>IgniteServices. cancelAllAsync(Collection<String> names)Asynchronously cancels services with specified names.IgniteFuture<Void>IgniteServices. cancelAsync(String name)Asynchronously cancels service deployment.IgniteFuture<Void>IgniteSnapshot. cancelSnapshot(String name)Cancel running snapshot operation.IgniteFuture<Boolean>IgniteSnapshot. cancelSnapshotRestore(String name)Cancel snapshot restore operation.IgniteFuture<Void>IgniteEncryption. changeCacheGroupKey(Collection<String> cacheOrGrpNames)Starts cache group encryption key change process.IgniteFuture<Void>IgniteEncryption. changeMasterKey(String masterKeyName)Starts master key change process.IgniteFuture<Void>IgniteCache. clearAllAsync(Set<? extends K> keys)Asynchronously clears entries from the cache and swap storage, without notifying listeners orCacheWriters.IgniteFuture<Void>IgniteCache. clearAsync()Asynchronously clears the contents of the cache, without notifying listeners orCacheWriters.IgniteFuture<Void>IgniteCache. clearAsync(K key)Asynchronously clears entry from the cache and swap storage, without notifying listeners orCacheWriters.@Nullable IgniteFuture<?>IgniteCluster. clientReconnectFuture()If local client node disconnected from cluster returns future that will be completed when client reconnected.IgniteFuture<Boolean>IgniteCache. containsKeyAsync(K key)Asynchronously determines if theCachecontains an entry for the specified key.IgniteFuture<Boolean>IgniteCache. containsKeysAsync(Set<? extends K> keys)Asynchronously determines if theCachecontains entries for the specified keys.IgniteFuture<Void>IgniteSnapshot. createDump(String name, @Nullable Collection<String> cacheGroupNames)Creates cache groups dump.IgniteFuture<Void>IgniteSnapshot. createIncrementalSnapshot(String snapshotName)Create an incremental snapshot for an existing snapshot.IgniteFuture<Void>IgniteSnapshot. createSnapshot(String name)Create a consistent copy of all persistence cache groups from the whole cluster.IgniteFuture<Void>IgniteServices. deployAllAsync(Collection<ServiceConfiguration> cfgs)Asynchronously deploys multiple services described by provided configurations.IgniteFuture<Void>IgniteServices. deployAsync(ServiceConfiguration cfg)Asynchronously deploys multiple instances of the service on the grid according to provided configuration.IgniteFuture<Void>IgniteServices. deployClusterSingletonAsync(String name, Service svc)Asynchronously deploys a cluster-wide singleton service.IgniteFuture<Void>IgniteServices. deployKeyAffinitySingletonAsync(String name, Service svc, @Nullable String cacheName, Object affKey)Asynchronously deploys one instance of this service on the primary node for a given affinity key.IgniteFuture<Void>IgniteServices. deployMultipleAsync(String name, Service svc, int totalCnt, int maxPerNodeCnt)Asynchronously deploys multiple instances of the service on the grid.IgniteFuture<Void>IgniteServices. deployNodeSingletonAsync(String name, Service svc)Asynchronously deploys a per-node singleton service.IgniteFuture<?>IgniteDataStreamer. future()Gets future for this streaming process.IgniteFuture<Map<K,V>>IgniteCache. getAllAsync(Set<? extends K> keys)Asynchronously gets a collection of entries from theCache, returning them asMapof the values associated with the set of keys requested.IgniteFuture<Map<K,V>>IgniteCache. getAllOutTxAsync(Set<? extends K> keys)Asynchronously gets values from cache.IgniteFuture<V>IgniteCache. getAndPutAsync(K key, V val)Asynchronously associates the specified value with the specified key in this cache, returning an existing value if one existed as the future result.IgniteFuture<V>IgniteCache. getAndPutIfAbsentAsync(K key, V val)Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.IgniteFuture<V>IgniteCache. getAndRemoveAsync(K key)Asynchronously removes the entry for a key only if currently mapped to some value.IgniteFuture<V>IgniteCache. getAndReplaceAsync(K key, V val)Asynchronously replaces the value for a given key if and only if there is a value currently mapped by the key.IgniteFuture<V>IgniteCache. getAsync(K key)Asynchronously gets an entry from the cache.IgniteFuture<Collection<CacheEntry<K,V>>>IgniteCache. getEntriesAsync(Set<? extends K> keys)Asynchronously gets a collection of entries from theCache.IgniteFuture<CacheEntry<K,V>>IgniteCache. getEntryAsync(K key)Asynchronously gets an entry from the cache.IgniteFuture<?>IgniteCache. indexReadyFuture()Returns future that will be completed when all indexes for this cache are ready to use.<T> IgniteFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>>IgniteCache. invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)Asynchronous version of theIgniteCache.invokeAll(Map, Object...)method.<T> IgniteFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>>IgniteCache. invokeAllAsync(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)Asynchronously invokes anEntryProcessoragainst the set ofCache.Entrys specified by the set of keys.<T> IgniteFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>>IgniteCache. invokeAllAsync(Set<? extends K> keys, CacheEntryProcessor<K,V,T> entryProcessor, Object... args)Asynchronously invokes anCacheEntryProcessoragainst the set ofCache.Entrys specified by the set of keys.<T> IgniteFuture<T>IgniteCache. invokeAsync(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... arguments)Asynchronously invokes anEntryProcessoragainst theCache.Entryspecified by the provided key.<T> IgniteFuture<T>IgniteCache. invokeAsync(K key, CacheEntryProcessor<K,V,T> entryProcessor, Object... arguments)Asynchronously invokes anCacheEntryProcessoragainst theCache.Entryspecified by the provided key.IgniteFuture<Void>IgniteCache. loadCacheAsync(@Nullable IgniteBiPredicate<K,V> p, @Nullable Object... args)Asynchronously executesIgniteCache.localLoadCache(IgniteBiPredicate, Object...)on all cache nodes.IgniteFuture<Void>IgniteCache. localLoadCacheAsync(@Nullable IgniteBiPredicate<K,V> p, @Nullable Object... args)Asynchronously loads state from the underlying persistent storage by delegating toCacheStore.loadCache(IgniteBiInClosure,Object...)method.IgniteFuture<Void>IgniteCache. preloadPartitionAsync(int partition)Efficiently preloads cache partition into page memory.IgniteFuture<Void>IgniteCache. putAllAsync(Map<? extends K,? extends V> map)Asynchronously copies all of the entries from the specified map to theCache.IgniteFuture<Void>IgniteCache. putAsync(K key, V val)Asynchronously associates the specified value with the specified key in the cache.IgniteFuture<Boolean>IgniteCache. putIfAbsentAsync(K key, V val)Asynchronously associates the specified key with the given value if it is not already associated with a value.IgniteFuture<Boolean>IgniteCache. rebalance()Deprecated.Use baseline topology feature instead.IgniteFuture<?>IgniteClientDisconnectedException. reconnectFuture()<T extends Event>
IgniteFuture<UUID>IgniteEvents. remoteListenAsync(int bufSize, long interval, boolean autoUnsubscribe, @Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable int... types)Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including local node if it belongs to the cluster group as well).<T extends Event>
IgniteFuture<UUID>IgniteEvents. remoteListenAsync(@Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable int... types)Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including local node if it belongs to the cluster group as well).IgniteFuture<UUID>IgniteMessaging. remoteListenAsync(@Nullable Object topic, IgniteBiPredicate<UUID,?> p)Asynchronously adds a message listener for a given topic to all nodes in the cluster group (possibly including this node if it belongs to the cluster group as well).<T extends Event>
IgniteFuture<List<T>>IgniteEvents. remoteQueryAsync(IgnitePredicate<T> p, long timeout, @org.jetbrains.annotations.Nullable int... types)Asynchronously queries nodes in this cluster group for events using passed in predicate filter for event selection.IgniteFuture<Void>IgniteCache. removeAllAsync()Asynchronously removes all of the mappings from this cache.IgniteFuture<Void>IgniteCache. removeAllAsync(Set<? extends K> keys)Asynchronously removes entries for the specified keys.IgniteFuture<Boolean>IgniteCache. removeAsync(K key)Asynchronously removes the mapping for a key from this cache if it is present.IgniteFuture<Boolean>IgniteCache. removeAsync(K key, V oldVal)Asynchronously removes the mapping for a key only if currently mapped to the given value.IgniteFuture<?>IgniteDataStreamer. removeData(K key)Adds key for removal on remote node.IgniteFuture<Boolean>IgniteCache. replaceAsync(K key, V val)Asynchronously replaces the entry for a key only if currently mapped to a given value.IgniteFuture<Boolean>IgniteCache. replaceAsync(K key, V oldVal, V newVal)Asynchronous version of theIgniteCache.replace(Object, Object, Object).IgniteFuture<?>IgniteCacheRestartingException. restartFuture()IgniteFuture<Void>IgniteSnapshot. restoreSnapshot(String name, @Nullable Collection<String> cacheGroupNames)Restore cache group(s) from the snapshot.IgniteFuture<Void>IgniteSnapshot. restoreSnapshot(String name, @Nullable Collection<String> cacheGroupNames, int incIdx)Restore cache group(s) from the snapshot and its increments.IgniteFuture<Void>IgniteCompute. runAsync(Collection<? extends IgniteRunnable> jobs)Executes collection of jobs asynchronously on grid nodes within the underlying cluster group.IgniteFuture<Void>IgniteCompute. runAsync(IgniteRunnable job)Executes provided job asynchronously on a node within the underlying cluster group.IgniteFuture<?>IgniteScheduler. runLocal(@NotNull Runnable r)Executes given closure on internal system thread pool asynchronously.IgniteFuture<Integer>IgniteCache. sizeAsync(CachePeekMode... peekModes)Asynchronously gets the number of all entries cached across all nodes.IgniteFuture<Long>IgniteCache. sizeLongAsync(int partition, CachePeekMode... peekModes)Asynchronously gets the number of all entries cached in a partition as a long value.IgniteFuture<Long>IgniteCache. sizeLongAsync(CachePeekMode... peekModes)Asynchronously gets the number of all entries cached across all nodes as a long value.IgniteFuture<Collection<ClusterStartNodeResult>>IgniteCluster. startNodesAsync(File file, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s) asynchronously.IgniteFuture<Collection<ClusterStartNodeResult>>IgniteCluster. startNodesAsync(Collection<Map<String,Object>> hosts, @Nullable Map<String,Object> dflts, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s) asynchronously.IgniteFuture<Void>IgniteEvents. stopRemoteListenAsync(UUID opId)Asynchronously stops listening to remote events.IgniteFuture<Void>IgniteMessaging. stopRemoteListenAsync(UUID opId)Asynchronously unregisters all listeners identified with provided operation ID on all nodes in the cluster group.<T extends Event>
IgniteFuture<T>IgniteEvents. waitForLocalAsync(@Nullable IgnitePredicate<T> filter, @org.jetbrains.annotations.Nullable int... types)Create future to wait for the specified events.Constructors in org.apache.ignite with parameters of type IgniteFuture Constructor Description IgniteCacheRestartingException(IgniteFuture<?> restartFut, String cacheName)IgniteCacheRestartingException(IgniteFuture<?> restartFut, String cacheName, @Nullable Throwable cause)IgniteClientDisconnectedException(IgniteFuture<?> reconnectFut, String msg)IgniteClientDisconnectedException(IgniteFuture<?> reconnectFut, String msg, @Nullable Throwable cause) -
Uses of IgniteFuture in org.apache.ignite.cluster
Methods in org.apache.ignite.cluster that return IgniteFuture Modifier and Type Method Description IgniteFuture<?>ClusterTopologyException. retryReadyFuture()Methods in org.apache.ignite.cluster with parameters of type IgniteFuture Modifier and Type Method Description voidClusterTopologyException. retryReadyFuture(IgniteFuture<?> readyFut) -
Uses of IgniteFuture in org.apache.ignite.compute
Subinterfaces of IgniteFuture in org.apache.ignite.compute Modifier and Type Interface Description interfaceComputeTaskFuture<R>This class defines a handler for asynchronous task execution.Methods in org.apache.ignite.compute that return IgniteFuture Modifier and Type Method Description IgniteFuture<?>ComputeTaskSession. mapFuture()Gets future that will be completed when task "map" step has completed (which means thatComputeTask.map(List, Object)method has finished). -
Uses of IgniteFuture in org.apache.ignite.internal
Fields in org.apache.ignite.internal with type parameters of type IgniteFuture Modifier and Type Field Description protected ThreadLocal<IgniteFuture<?>>AsyncSupportAdapter. curFutFuture for previous asynchronous operation.Methods in org.apache.ignite.internal that return IgniteFuture Modifier and Type Method Description <R> IgniteFuture<R>IgniteComputeImpl. affinityCallAsync(@NotNull Collection<String> cacheNames, int partId, IgniteCallable<R> job)Executes given job asynchronously on the node where partition is located (the partition is primary on the node) The data of the partition will not be migrated from the target node while the job is executed.<R> IgniteFuture<R>IgniteComputeImpl. affinityCallAsync(@NotNull Collection<String> cacheNames, Object affKey, IgniteCallable<R> job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).<R> IgniteFuture<R>IgniteComputeImpl. affinityCallAsync(String cacheName, Object affKey, IgniteCallable<R> job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).IgniteFuture<Void>IgniteComputeImpl. affinityRunAsync(@NotNull Collection<String> cacheNames, int partId, IgniteRunnable job)Executes given job asynchronously on the node where partition is located (the partition is primary on the node) The data of the partition will not be migrated from the target node while the job is executed.IgniteFuture<Void>IgniteComputeImpl. affinityRunAsync(@NotNull Collection<String> cacheNames, Object affKey, IgniteRunnable job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).IgniteFuture<Void>IgniteComputeImpl. affinityRunAsync(String cacheName, Object affKey, IgniteRunnable job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).<T,R>
IgniteFuture<Collection<R>>IgniteComputeImpl. applyAsync(IgniteClosure<T,R> job, Collection<? extends T> args)Executes provided closure job asynchronously on nodes within the underlying cluster group.<R,T>
IgniteFuture<R>IgniteComputeImpl. applyAsync(IgniteClosure<T,R> job, T arg)Executes provided closure job asynchronously on a node within the underlying cluster group.<R1,R2,T>
IgniteFuture<R2>IgniteComputeImpl. applyAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc)Executes provided closure job asynchronously on nodes within the underlying cluster group.<R> IgniteFuture<Collection<R>>IgniteComputeImpl. broadcastAsync(IgniteCallable<R> job)Broadcasts given job asynchronously to all nodes in cluster group.<R,T>
IgniteFuture<Collection<R>>IgniteComputeImpl. broadcastAsync(IgniteClosure<T,R> job, T arg)Broadcasts given closure job asynchronously with passed in argument to all nodes in the cluster group.IgniteFuture<Void>IgniteComputeImpl. broadcastAsync(IgniteRunnable job)Broadcasts given job asynchronously to all nodes in the cluster group.<R> IgniteFuture<Collection<R>>IgniteComputeImpl. callAsync(Collection<? extends IgniteCallable<R>> jobs)Executes collection of jobs asynchronously on nodes within the underlying cluster group.<R1,R2>
IgniteFuture<R2>IgniteComputeImpl. callAsync(Collection<? extends IgniteCallable<R1>> jobs, IgniteReducer<R1,R2> rdc)Executes collection of jobs asynchronously on nodes within the underlying cluster group.<R> IgniteFuture<R>IgniteComputeImpl. callAsync(IgniteCallable<R> job)Executes provided job asynchronously on a node within the underlying cluster group.<R> IgniteFuture<R>IgniteSchedulerImpl. callLocal(@NotNull Callable<R> c)Executes given callable on internal system thread pool asynchronously.IgniteFuture<Void>IgniteServicesImpl. cancelAllAsync()Asynchronously cancels all deployed services.IgniteFuture<Void>IgniteServicesImpl. cancelAllAsync(Collection<String> names)Asynchronously cancels services with specified names.IgniteFuture<Void>IgniteServicesImpl. cancelAsync(String name)Asynchronously cancels service deployment.protected <R> IgniteFuture<R>AsyncSupportAdapter. createFuture(IgniteInternalFuture<R> fut)protected <R> IgniteFuture<R>IgniteComputeImpl. createFuture(IgniteInternalFuture<R> fut)IgniteFuture<Void>IgniteServicesImpl. deployAllAsync(Collection<ServiceConfiguration> cfgs)Asynchronously deploys multiple services described by provided configurations.IgniteFuture<Void>IgniteServicesImpl. deployAsync(ServiceConfiguration cfg)Asynchronously deploys multiple instances of the service on the grid according to provided configuration.IgniteFuture<Void>IgniteServicesImpl. deployClusterSingletonAsync(String name, Service svc)Asynchronously deploys a cluster-wide singleton service.IgniteFuture<Void>IgniteServicesImpl. deployKeyAffinitySingletonAsync(String name, Service svc, @Nullable String cacheName, Object affKey)Asynchronously deploys one instance of this service on the primary node for a given affinity key.IgniteFuture<Void>IgniteServicesImpl. deployMultipleAsync(String name, Service svc, int totalCnt, int maxPerNodeCnt)Asynchronously deploys multiple instances of the service on the grid.IgniteFuture<Void>IgniteServicesImpl. deployNodeSingletonAsync(String name, Service svc)Asynchronously deploys a per-node singleton service.<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 thatComputeTask.map(List, Object)method has finished).IgniteFuture<?>GridTaskSessionImpl. mapFuture()Gets future that will be completed when task "map" step has completed (which means thatComputeTask.map(List, Object)method has finished).IgniteFuture<?>IgniteClientDisconnectedCheckedException. reconnectFuture()<T extends Event>
IgniteFuture<UUID>IgniteEventsImpl. remoteListenAsync(int bufSize, long interval, boolean autoUnsubscribe, @Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable int... types)Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including local node if it belongs to the cluster group as well).<T extends Event>
IgniteFuture<UUID>IgniteEventsImpl. remoteListenAsync(@Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable int... types)Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including local node if it belongs to the cluster group as well).IgniteFuture<UUID>IgniteMessagingImpl. remoteListenAsync(@Nullable Object topic, IgniteBiPredicate<UUID,?> p)Asynchronously adds a message listener for a given topic to all nodes in the cluster group (possibly including this node if it belongs to the cluster group as well).<T extends Event>
IgniteFuture<List<T>>IgniteEventsImpl. remoteQueryAsync(IgnitePredicate<T> p, long timeout, @org.jetbrains.annotations.Nullable int... types)Asynchronously queries nodes in this cluster group for events using passed in predicate filter for event selection.IgniteFuture<Void>IgniteComputeImpl. runAsync(Collection<? extends IgniteRunnable> jobs)Executes collection of jobs asynchronously on grid nodes within the underlying cluster group.IgniteFuture<Void>IgniteComputeImpl. runAsync(IgniteRunnable job)Executes provided job asynchronously on a node within the underlying cluster group.IgniteFuture<?>IgniteSchedulerImpl. runLocal(@NotNull Runnable r)Executes given closure on internal system thread pool asynchronously.IgniteFuture<Void>IgniteEventsImpl. stopRemoteListenAsync(UUID opId)Asynchronously stops listening to remote events.IgniteFuture<Void>IgniteMessagingImpl. stopRemoteListenAsync(UUID opId)Asynchronously unregisters all listeners identified with provided operation ID on all nodes in the cluster group.<T extends Event>
IgniteFuture<T>IgniteEventsImpl. waitForLocalAsync(@Nullable IgnitePredicate<T> filter, @org.jetbrains.annotations.Nullable int... types)Create future to wait for the specified events.Methods in org.apache.ignite.internal with parameters of type IgniteFuture Modifier and Type Method Description voidGridComponent. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback.voidGridPluginComponent. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback.Constructors in org.apache.ignite.internal with parameters of type IgniteFuture Constructor Description IgniteClientDisconnectedCheckedException(IgniteFuture<?> reconnectFut, String msg) -
Uses of IgniteFuture in org.apache.ignite.internal.cluster
Methods in org.apache.ignite.internal.cluster that return IgniteFuture Modifier and Type Method Description IgniteFuture<?>IgniteClusterAsyncImpl. baselineAutoAdjustEnabledAsync(boolean baselineAutoAdjustEnabled)IgniteFuture<?>IgniteClusterImpl. baselineAutoAdjustEnabledAsync(boolean baselineAutoAdjustEnabled)IgniteFuture<?>IgniteClusterAsyncImpl. baselineAutoAdjustTimeoutAsync(long baselineAutoAdjustTimeout)IgniteFuture<?>IgniteClusterImpl. baselineAutoAdjustTimeoutAsync(long baselineAutoAdjustTimeout)@Nullable IgniteFuture<?>IgniteClusterAsyncImpl. clientReconnectFuture()If local client node disconnected from cluster returns future that will be completed when client reconnected.@Nullable 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.IgniteFuture<Collection<ClusterStartNodeResult>>IgniteClusterAsyncImpl. startNodesAsync(File file, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s) asynchronously.IgniteFuture<Collection<ClusterStartNodeResult>>IgniteClusterAsyncImpl. startNodesAsync(Collection<Map<String,Object>> hosts, @Nullable Map<String,Object> dflts, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s) asynchronously.IgniteFuture<Collection<ClusterStartNodeResult>>IgniteClusterImpl. startNodesAsync(File file, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s) asynchronously.IgniteFuture<Collection<ClusterStartNodeResult>>IgniteClusterImpl. startNodesAsync(Collection<Map<String,Object>> hosts, @Nullable Map<String,Object> dflts, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s) asynchronously.Methods in org.apache.ignite.internal.cluster with parameters of type IgniteFuture Modifier and Type Method Description voidIgniteClusterImpl. clientReconnectFuture(IgniteFuture<?> reconnecFut) -
Uses of IgniteFuture in org.apache.ignite.internal.managers
Methods in org.apache.ignite.internal.managers with parameters of type IgniteFuture Modifier and Type Method Description voidGridManagerAdapter. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.managers.deployment
Methods in org.apache.ignite.internal.managers.deployment with parameters of type IgniteFuture Modifier and Type Method Description voidGridDeploymentManager. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.managers.encryption
Methods in org.apache.ignite.internal.managers.encryption that return IgniteFuture Modifier and Type Method Description IgniteFuture<Void>GridEncryptionManager. changeCacheGroupKey(Collection<String> cacheOrGrpNames)Starts cache group encryption key change process.IgniteFuture<Void>GridEncryptionManager. changeMasterKey(String masterKeyName)Starts master key change process.Methods in org.apache.ignite.internal.managers.encryption with parameters of type IgniteFuture Modifier and Type Method Description voidGridEncryptionManager. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors
Methods in org.apache.ignite.internal.processors with parameters of type IgniteFuture Modifier and Type Method Description voidGridProcessorAdapter. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.affinity
Methods in org.apache.ignite.internal.processors.affinity with parameters of type IgniteFuture Modifier and Type Method Description voidGridAffinityProcessor. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.authentication
Methods in org.apache.ignite.internal.processors.authentication with parameters of type IgniteFuture Modifier and Type Method Description voidIgniteAuthenticationProcessor. onDisconnected(IgniteFuture reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.cache
Classes in org.apache.ignite.internal.processors.cache that implement IgniteFuture Modifier and Type Class Description classIgniteCacheFutureImpl<V>Implementation of public API future for cache.classIgniteFinishedCacheFutureImpl<V>Methods in org.apache.ignite.internal.processors.cache that return IgniteFuture Modifier and Type Method 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.<T> IgniteFuture<T>IgniteCacheFutureImpl. chainAsync(IgniteClosure<? super IgniteFuture<V>,T> doneCb, Executor exec)Make a chained future to convert result of this future (when complete) into a new format.IgniteFuture<Void>GatewayProtectedCacheProxy. clearAllAsync(Set<? extends K> keys)Asynchronously clears entries from the cache and swap storage, without notifying listeners orCacheWriters.IgniteFuture<Void>IgniteCacheProxyImpl. clearAllAsync(Set<? extends K> keys)Asynchronously clears entries from the cache and swap storage, without notifying listeners orCacheWriters.IgniteFuture<Void>GatewayProtectedCacheProxy. clearAsync()Asynchronously clears the contents of the cache, without notifying listeners orCacheWriters.IgniteFuture<Void>GatewayProtectedCacheProxy. clearAsync(K key)Asynchronously clears entry from the cache and swap storage, without notifying listeners orCacheWriters.IgniteFuture<Void>IgniteCacheProxyImpl. clearAsync()Asynchronously clears the contents of the cache, without notifying listeners orCacheWriters.IgniteFuture<Void>IgniteCacheProxyImpl. clearAsync(K key)Asynchronously clears entry from the cache and swap storage, without notifying listeners orCacheWriters.IgniteFuture<?>GatewayProtectedCacheProxy. closeAsync()IgniteFuture<?>IgniteCacheProxy. closeAsync()IgniteFuture<?>IgniteCacheProxyImpl. closeAsync()IgniteFuture<Boolean>GatewayProtectedCacheProxy. containsKeyAsync(K key)Asynchronously determines if theCachecontains an entry for the specified key.IgniteFuture<Boolean>IgniteCacheProxyImpl. containsKeyAsync(K key)Asynchronously determines if theCachecontains an entry for the specified key.IgniteFuture<Boolean>GatewayProtectedCacheProxy. containsKeysAsync(Set<? extends K> keys)Asynchronously determines if theCachecontains entries for the specified keys.IgniteFuture<Boolean>IgniteCacheProxyImpl. containsKeysAsync(Set<? extends K> keys)Asynchronously determines if theCachecontains entries for the specified keys.protected <R> IgniteFuture<R>IgniteCacheProxyImpl. createFuture(IgniteInternalFuture<R> fut)IgniteFuture<?>GatewayProtectedCacheProxy. destroyAsync()IgniteFuture<?>IgniteCacheProxy. destroyAsync()IgniteFuture<?>IgniteCacheProxyImpl. destroyAsync()<R> IgniteFuture<R>GatewayProtectedCacheProxy. future()Gets and resets future for previous asynchronous operation.IgniteFuture<Map<K,V>>GatewayProtectedCacheProxy. getAllAsync(Set<? extends K> keys)Asynchronously gets a collection of entries from theCache, returning them asMapof the values associated with the set of keys requested.IgniteFuture<Map<K,V>>IgniteCacheProxyImpl. getAllAsync(Set<? extends K> keys)Asynchronously gets a collection of entries from theCache, returning them asMapof the values associated with the set of keys requested.IgniteFuture<Map<K,V>>GatewayProtectedCacheProxy. getAllOutTxAsync(Set<? extends K> keys)Asynchronously gets values from cache.IgniteFuture<Map<K,V>>IgniteCacheProxyImpl. getAllOutTxAsync(Set<? extends K> keys)Asynchronously gets values from cache.IgniteFuture<V>GatewayProtectedCacheProxy. getAndPutAsync(K key, V val)Asynchronously associates the specified value with the specified key in this cache, returning an existing value if one existed as the future result.IgniteFuture<V>IgniteCacheProxyImpl. getAndPutAsync(K key, V val)Asynchronously associates the specified value with the specified key in this cache, returning an existing value if one existed as the future result.IgniteFuture<V>GatewayProtectedCacheProxy. getAndPutIfAbsentAsync(K key, V val)Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.IgniteFuture<V>IgniteCacheProxyImpl. getAndPutIfAbsentAsync(K key, V val)Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.IgniteFuture<V>GatewayProtectedCacheProxy. getAndRemoveAsync(K key)Asynchronously removes the entry for a key only if currently mapped to some value.IgniteFuture<V>IgniteCacheProxyImpl. getAndRemoveAsync(K key)Asynchronously removes the entry for a key only if currently mapped to some value.IgniteFuture<V>GatewayProtectedCacheProxy. getAndReplaceAsync(K key, V val)Asynchronously replaces the value for a given key if and only if there is a value currently mapped by the key.IgniteFuture<V>IgniteCacheProxyImpl. getAndReplaceAsync(K key, V val)Asynchronously replaces the value for a given key if and only if there is a value currently mapped by the key.IgniteFuture<V>GatewayProtectedCacheProxy. getAsync(K key)Asynchronously gets an entry from the cache.IgniteFuture<V>IgniteCacheProxyImpl. getAsync(K key)Asynchronously gets an entry from the cache.IgniteFuture<Collection<CacheEntry<K,V>>>GatewayProtectedCacheProxy. getEntriesAsync(Set<? extends K> keys)Asynchronously gets a collection of entries from theCache.IgniteFuture<Collection<CacheEntry<K,V>>>IgniteCacheProxyImpl. getEntriesAsync(Set<? extends K> keys)Asynchronously gets a collection of entries from theCache.IgniteFuture<CacheEntry<K,V>>GatewayProtectedCacheProxy. getEntryAsync(K key)Asynchronously gets an entry from the cache.IgniteFuture<CacheEntry<K,V>>IgniteCacheProxyImpl. getEntryAsync(K key)Asynchronously gets an entry from the cache.IgniteFuture<?>GatewayProtectedCacheProxy. indexReadyFuture()Returns future that will be completed when all indexes for this cache are ready to use.IgniteFuture<?>IgniteCacheProxyImpl. indexReadyFuture()Returns future that will be completed when all indexes for this cache are ready to use.<T> IgniteFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>>GatewayProtectedCacheProxy. invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)Asynchronous version of theIgniteCache.invokeAll(Map, Object...)method.<T> IgniteFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>>GatewayProtectedCacheProxy. invokeAllAsync(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)Asynchronously invokes anEntryProcessoragainst the set ofCache.Entrys specified by the set of keys.<T> IgniteFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>>GatewayProtectedCacheProxy. invokeAllAsync(Set<? extends K> keys, CacheEntryProcessor<K,V,T> entryProcessor, Object... args)Asynchronously invokes anCacheEntryProcessoragainst the set ofCache.Entrys specified by the set of keys.<T> IgniteFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>>IgniteCacheProxyImpl. invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)Asynchronous version of theIgniteCache.invokeAll(Map, Object...)method.<T> IgniteFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>>IgniteCacheProxyImpl. invokeAllAsync(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)Asynchronously invokes anEntryProcessoragainst the set ofCache.Entrys specified by the set of keys.<T> IgniteFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>>IgniteCacheProxyImpl. invokeAllAsync(Set<? extends K> keys, CacheEntryProcessor<K,V,T> entryProcessor, Object... args)Asynchronously invokes anCacheEntryProcessoragainst the set ofCache.Entrys specified by the set of keys.<T> IgniteFuture<T>GatewayProtectedCacheProxy. invokeAsync(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... arguments)Asynchronously invokes anEntryProcessoragainst theCache.Entryspecified by the provided key.<T> IgniteFuture<T>GatewayProtectedCacheProxy. invokeAsync(K key, CacheEntryProcessor<K,V,T> entryProcessor, Object... arguments)Asynchronously invokes anCacheEntryProcessoragainst theCache.Entryspecified by the provided key.<T> IgniteFuture<T>IgniteCacheProxyImpl. invokeAsync(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)Asynchronously invokes anEntryProcessoragainst theCache.Entryspecified by the provided key.<T> IgniteFuture<T>IgniteCacheProxyImpl. invokeAsync(K key, CacheEntryProcessor<K,V,T> entryProcessor, Object... args)Asynchronously invokes anCacheEntryProcessoragainst theCache.Entryspecified by the provided key.IgniteFuture<Void>GatewayProtectedCacheProxy. loadCacheAsync(@Nullable IgniteBiPredicate<K,V> p, @Nullable Object... args)Asynchronously executesIgniteCache.localLoadCache(IgniteBiPredicate, Object...)on all cache nodes.IgniteFuture<Void>IgniteCacheProxyImpl. loadCacheAsync(@Nullable IgniteBiPredicate<K,V> p, @Nullable Object... args)Asynchronously executesIgniteCache.localLoadCache(IgniteBiPredicate, Object...)on all cache nodes.IgniteFuture<Void>GatewayProtectedCacheProxy. localLoadCacheAsync(@Nullable IgniteBiPredicate<K,V> p, @Nullable Object... args)Asynchronously loads state from the underlying persistent storage by delegating toCacheStore.loadCache(IgniteBiInClosure,Object...)method.IgniteFuture<Void>IgniteCacheProxyImpl. localLoadCacheAsync(@Nullable IgniteBiPredicate<K,V> p, @Nullable Object... args)Asynchronously loads state from the underlying persistent storage by delegating toCacheStore.loadCache(IgniteBiInClosure,Object...)method.IgniteFuture<Void>GatewayProtectedCacheProxy. preloadPartitionAsync(int part)Efficiently preloads cache partition into page memory.IgniteFuture<Void>IgniteCacheProxyImpl. preloadPartitionAsync(int part)Efficiently preloads cache partition into page memory.IgniteFuture<Void>GatewayProtectedCacheProxy. putAllAsync(Map<? extends K,? extends V> map)Asynchronously copies all of the entries from the specified map to theCache.IgniteFuture<Void>IgniteCacheProxyImpl. putAllAsync(Map<? extends K,? extends V> map)Asynchronously copies all of the entries from the specified map to theCache.IgniteFuture<Void>GatewayProtectedCacheProxy. putAsync(K key, V val)Asynchronously associates the specified value with the specified key in the cache.IgniteFuture<Void>IgniteCacheProxyImpl. putAsync(K key, V val)Asynchronously associates the specified value with the specified key in the cache.IgniteFuture<Boolean>GatewayProtectedCacheProxy. putIfAbsentAsync(K key, V val)Asynchronously associates the specified key with the given value if it is not already associated with a value.IgniteFuture<Boolean>IgniteCacheProxyImpl. putIfAbsentAsync(K key, V val)Asynchronously associates the specified key with the given value if it is not already associated with a value.IgniteFuture<Boolean>GatewayProtectedCacheProxy. rebalance()This cache node to re-balance its partitions.IgniteFuture<Boolean>IgniteCacheProxyImpl. rebalance()This cache node to re-balance its partitions.IgniteFuture<Void>GatewayProtectedCacheProxy. removeAllAsync()Asynchronously removes all of the mappings from this cache.IgniteFuture<Void>GatewayProtectedCacheProxy. removeAllAsync(Set<? extends K> keys)Asynchronously removes entries for the specified keys.IgniteFuture<Void>IgniteCacheProxyImpl. removeAllAsync()Asynchronously removes all of the mappings from this cache.IgniteFuture<Void>IgniteCacheProxyImpl. removeAllAsync(Set<? extends K> keys)Asynchronously removes entries for the specified keys.IgniteFuture<Boolean>GatewayProtectedCacheProxy. removeAsync(K key)Asynchronously removes the mapping for a key from this cache if it is present.IgniteFuture<Boolean>GatewayProtectedCacheProxy. removeAsync(K key, V oldVal)Asynchronously removes the mapping for a key only if currently mapped to the given value.IgniteFuture<Boolean>IgniteCacheProxyImpl. removeAsync(K key)Asynchronously removes the mapping for a key from this cache if it is present.IgniteFuture<Boolean>IgniteCacheProxyImpl. removeAsync(K key, V oldVal)Asynchronously removes the mapping for a key only if currently mapped to the given value.IgniteFuture<Boolean>GatewayProtectedCacheProxy. replaceAsync(K key, V val)Asynchronously replaces the entry for a key only if currently mapped to a given value.IgniteFuture<Boolean>GatewayProtectedCacheProxy. replaceAsync(K key, V oldVal, V newVal)Asynchronous version of theIgniteCache.replace(Object, Object, Object).IgniteFuture<Boolean>IgniteCacheProxyImpl. replaceAsync(K key, V val)Asynchronously replaces the entry for a key only if currently mapped to a given value.IgniteFuture<Boolean>IgniteCacheProxyImpl. replaceAsync(K key, V oldVal, V newVal)Asynchronous version of theIgniteCache.replace(Object, Object, Object).IgniteFuture<Integer>GatewayProtectedCacheProxy. sizeAsync(CachePeekMode... peekModes)Asynchronously gets the number of all entries cached across all nodes.IgniteFuture<Integer>IgniteCacheProxyImpl. sizeAsync(CachePeekMode... peekModes)Asynchronously gets the number of all entries cached across all nodes.IgniteFuture<Long>GatewayProtectedCacheProxy. sizeLongAsync(int partition, CachePeekMode... peekModes)Asynchronously gets the number of all entries cached in a partition as a long value.IgniteFuture<Long>GatewayProtectedCacheProxy. sizeLongAsync(CachePeekMode... peekModes)Asynchronously gets the number of all entries cached across all nodes as a long value.IgniteFuture<Long>IgniteCacheProxyImpl. sizeLongAsync(int part, CachePeekMode... peekModes)Asynchronously gets the number of all entries cached in a partition as a long value.IgniteFuture<Long>IgniteCacheProxyImpl. sizeLongAsync(CachePeekMode... peekModes)Asynchronously gets the number of all entries cached across all nodes as a long value.Methods in org.apache.ignite.internal.processors.cache with parameters of type IgniteFuture Modifier and Type Method Description voidCacheGroupContext. onDisconnected(IgniteFuture reconnectFut)voidCacheOsConflictResolutionManager. onDisconnected(IgniteFuture<?> reconnectFut)voidGridCacheGateway. onDisconnected(IgniteFuture<?> reconnectFut)voidGridCacheManager. onDisconnected(IgniteFuture<?> reconnectFut)voidGridCacheManagerAdapter. onDisconnected(IgniteFuture<?> reconnectFut)voidGridCacheMvccManager. onDisconnected(IgniteFuture reconnectFut)voidGridCacheProcessor. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback.voidGridCacheSharedManager. onDisconnected(IgniteFuture<?> reconnectFut)voidGridCacheSharedManagerAdapter. onDisconnected(IgniteFuture<?> reconnectFut)voidWalStateManager. onDisconnected(IgniteFuture reconnectFut)Method parameters in org.apache.ignite.internal.processors.cache with type arguments of type IgniteFuture Modifier and Type Method 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.<T> IgniteFuture<T>IgniteCacheFutureImpl. chainAsync(IgniteClosure<? super IgniteFuture<V>,T> doneCb, Executor exec)Make a chained future to convert result of this future (when complete) into a new format. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.cache.binary
Methods in org.apache.ignite.internal.processors.cache.binary with parameters of type IgniteFuture Modifier and Type Method Description voidCacheObjectBinaryProcessorImpl. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.cache.datastructures
Methods in org.apache.ignite.internal.processors.cache.datastructures with parameters of type IgniteFuture Modifier and Type Method Description voidCacheDataStructuresManager. onDisconnected(IgniteFuture reconnectFut) -
Uses of IgniteFuture in org.apache.ignite.internal.processors.cache.dr
Methods in org.apache.ignite.internal.processors.cache.dr with parameters of type IgniteFuture Modifier and Type Method Description voidGridOsCacheDrManager. onDisconnected(IgniteFuture reconnectFut) -
Uses of IgniteFuture in org.apache.ignite.internal.processors.cache.persistence.snapshot
Methods in org.apache.ignite.internal.processors.cache.persistence.snapshot that return IgniteFuture Modifier and Type Method Description IgniteFuture<Boolean>SnapshotRestoreProcess. cancel(UUID reqId, String snpName)Cancel the currently running local restore procedure.IgniteFuture<Boolean>IgniteSnapshotManager. cancelLocalRestoreTask(String name)Deprecated.IgniteFuture<Void>IgniteSnapshotManager. cancelSnapshot(String name)Cancel running snapshot operation.IgniteFuture<Boolean>IgniteSnapshotManager. cancelSnapshotOperation(UUID reqId)IgniteFuture<Boolean>IgniteSnapshotManager. cancelSnapshotRestore(String name)Cancel snapshot restore operation.IgniteFuture<Void>IgniteSnapshotManager. createDump(String name, @Nullable Collection<String> cacheGrpNames)Creates cache groups dump.IgniteFuture<Void>IgniteSnapshotManager. createIncrementalSnapshot(String name)Create an incremental snapshot for an existing snapshot.IgniteFuture<Void>IgniteSnapshotManager. createSnapshot(String name)Create a consistent copy of all persistence cache groups from the whole cluster.IgniteFuture<Void>IgniteSnapshotManager. restoreSnapshot(String name, @Nullable Collection<String> grpNames)Restore cache group(s) from the snapshot.IgniteFuture<Void>IgniteSnapshotManager. restoreSnapshot(String name, @Nullable Collection<String> grpNames, int incIdx)Restore cache group(s) from the snapshot and its increments.IgniteFuture<Boolean>IgniteSnapshotManager. restoreStatus(String snpName)Status of the restore operation cluster-wide. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.cache.query
Methods in org.apache.ignite.internal.processors.cache.query with parameters of type IgniteFuture Modifier and Type Method Description voidGridCacheDistributedQueryManager. onDisconnected(IgniteFuture<?> reconnectFut) -
Uses of IgniteFuture in org.apache.ignite.internal.processors.cache.transactions
Methods in org.apache.ignite.internal.processors.cache.transactions that return IgniteFuture Modifier and Type Method Description IgniteFuture<Void>TransactionEventProxyImpl. commitAsync()Asynchronously commits this transaction by initiatingtwo-phase-commitprocess.IgniteFuture<Void>TransactionProxyImpl. commitAsync()Asynchronously commits this transaction by initiatingtwo-phase-commitprocess.IgniteFuture<Void>TransactionProxyRollbackOnlyImpl. commitAsync()Asynchronously commits this transaction by initiatingtwo-phase-commitprocess.<R> IgniteFuture<R>TransactionEventProxyImpl. future()Gets and resets future for previous asynchronous operation.<R> IgniteFuture<R>TransactionProxyImpl. future()Gets and resets future for previous asynchronous operation.IgniteFuture<Void>TransactionEventProxyImpl. rollbackAsync()Asynchronously rolls back this transaction.IgniteFuture<Void>TransactionProxyImpl. rollbackAsync()Asynchronously rolls back this transaction.Methods in org.apache.ignite.internal.processors.cache.transactions with parameters of type IgniteFuture Modifier and Type Method Description voidIgniteTxManager. onDisconnected(IgniteFuture reconnectFut) -
Uses of IgniteFuture in org.apache.ignite.internal.processors.cluster
Methods in org.apache.ignite.internal.processors.cluster that return IgniteFuture Modifier and Type Method Description IgniteFuture<?>GridClusterStateProcessor. baselineAutoAdjustEnabledAsync(boolean baselineAutoAdjustEnabled)IgniteFuture<?>GridClusterStateProcessor. baselineAutoAdjustTimeoutAsync(long baselineAutoAdjustTimeout)IgniteFuture<?>ClusterProcessor. clientReconnectFuture()IgniteFuture<Boolean>GridClusterStateProcessor. publicApiActiveStateAsync(boolean asyncWaitForTransition)IgniteFuture<Boolean>IGridClusterStateProcessor. publicApiActiveStateAsync(boolean waitForTransition)Deprecated.IgniteFuture<ClusterState>GridClusterStateProcessor. publicApiStateAsync(boolean asyncWaitForTransition)IgniteFuture<ClusterState>IGridClusterStateProcessor. publicApiStateAsync(boolean waitForTransition)Methods in org.apache.ignite.internal.processors.cluster with parameters of type IgniteFuture Modifier and Type Method Description voidClusterProcessor. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.continuous
Methods in org.apache.ignite.internal.processors.continuous with parameters of type IgniteFuture Modifier and Type Method Description voidGridContinuousProcessor. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.datastreamer
Methods in org.apache.ignite.internal.processors.datastreamer that return IgniteFuture Modifier and Type Method Description IgniteFuture<?>DataStreamerImpl. addData(Collection<? extends Map.Entry<K,V>> entries)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. addData(K key, V val)Adds data for streaming on remote node.IgniteFuture<?>DataStreamerImpl. addDataInternal(Collection<? extends DataStreamerEntry> entries)IgniteFuture<?>DataStreamerImpl. addDataInternal(Collection<? extends DataStreamerEntry> entries, boolean useThreadBuffer)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)Methods in org.apache.ignite.internal.processors.datastreamer with parameters of type IgniteFuture Modifier and Type Method Description voidDataStreamerImpl. onDisconnected(IgniteFuture<?> reconnectFut)voidDataStreamProcessor. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.datastructures
Methods in org.apache.ignite.internal.processors.datastructures that return IgniteFuture Modifier and Type Method Description <T> IgniteFuture<T>GridCacheSemaphoreImpl. acquireAndExecute(IgniteCallable<T> callable, int numPermits)Acquires the given semaphore, executes the given callable and schedules the release of permits asynchronously -
Uses of IgniteFuture in org.apache.ignite.internal.processors.marshaller
Methods in org.apache.ignite.internal.processors.marshaller with parameters of type IgniteFuture Modifier and Type Method Description voidGridMarshallerMappingProcessor. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.metastorage.persistence
Methods in org.apache.ignite.internal.processors.metastorage.persistence with parameters of type IgniteFuture Modifier and Type Method Description voidDistributedMetaStorageImpl. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.performancestatistics
Methods in org.apache.ignite.internal.processors.performancestatistics with parameters of type IgniteFuture Modifier and Type Method Description voidPerformanceStatisticsProcessor. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.platform
Methods in org.apache.ignite.internal.processors.platform that return IgniteFuture Modifier and Type Method Description IgniteFuturePlatformAsyncResult. future()Async operation future.Methods in org.apache.ignite.internal.processors.platform with parameters of type IgniteFuture Modifier and Type Method Description voidPlatformProcessorImpl. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback.protected PlatformListenablePlatformAbstractTarget. readAndListenFuture(BinaryRawReader reader, IgniteFuture fut)Reads future information and listens.protected PlatformListenablePlatformAbstractTarget. readAndListenFuture(BinaryRawReader reader, IgniteFuture fut, PlatformFutureUtils.Writer writer)Reads future information and listens. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.platform.cache
Methods in org.apache.ignite.internal.processors.platform.cache with parameters of type IgniteFuture Modifier and Type Method Description voidPlatformCacheManager. onDisconnected(IgniteFuture reconnectFut) -
Uses of IgniteFuture in org.apache.ignite.internal.processors.platform.utils
Methods in org.apache.ignite.internal.processors.platform.utils with parameters of type IgniteFuture Modifier and Type Method Description static PlatformListenablePlatformFutureUtils. getListenable(IgniteFuture fut)Gets the listenable.static PlatformListenablePlatformFutureUtils. listen(PlatformContext ctx, IgniteFuture fut, long futPtr, int typ, PlatformTarget target)Listen future.static PlatformListenablePlatformFutureUtils. listen(PlatformContext ctx, IgniteFuture fut, long futPtr, int typ, PlatformFutureUtils.Writer writer, PlatformTarget target)Listen future. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.query
Methods in org.apache.ignite.internal.processors.query with parameters of type IgniteFuture Modifier and Type Method Description voidGridQueryIndexing. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback.voidGridQueryProcessor. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.security
Methods in org.apache.ignite.internal.processors.security with parameters of type IgniteFuture Modifier and Type Method Description voidIgniteSecurityProcessor. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.service
Methods in org.apache.ignite.internal.processors.service with parameters of type IgniteFuture Modifier and Type Method Description voidIgniteServiceProcessor. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.processors.task
Methods in org.apache.ignite.internal.processors.task with parameters of type IgniteFuture Modifier and Type Method Description voidGridTaskProcessor. onDisconnected(IgniteFuture<?> reconnectFut)Client disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.internal.util
Methods in org.apache.ignite.internal.util that return IgniteFuture Modifier and Type Method Description static IgniteFuture<Void>IgniteUtils. broadcastToNodesWithFilterAsync(GridKernalContext kctx, IgniteRunnable job, boolean srvrsOnly, IgnitePredicate<ClusterNode> nodeFilter)Broadcasts given job to nodes that match filter. -
Uses of IgniteFuture in org.apache.ignite.internal.util.future
Classes in org.apache.ignite.internal.util.future that implement IgniteFuture Modifier and Type Class Description classIgniteFinishedFutureImpl<V>classIgniteFutureImpl<V>Implementation of public API future.Methods in org.apache.ignite.internal.util.future that return IgniteFuture Modifier and Type Method 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.<T> IgniteFuture<T>IgniteFutureImpl. chainAsync(IgniteClosure<? super IgniteFuture<V>,T> doneCb, Executor exec)Make a chained future to convert result of this future (when complete) into a new format.Methods in org.apache.ignite.internal.util.future with parameters of type IgniteFuture Modifier and Type Method Description voidAsyncFutureListener. apply(IgniteFuture<V> fut)Closure body.Method parameters in org.apache.ignite.internal.util.future with type arguments of type IgniteFuture Modifier and Type Method 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.<T> IgniteFuture<T>IgniteFutureImpl. chainAsync(IgniteClosure<? super IgniteFuture<V>,T> doneCb, Executor exec)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, @Nullable Executor exec)voidIgniteFutureImpl. listen(IgniteInClosure<? super IgniteFuture<V>> lsnr)Registers a callback to be invoked when the future completes.voidIgniteFutureImpl. listenAsync(IgniteInClosure<? super IgniteFuture<V>> lsnr, Executor exec)Registers a callback to be invoked with the specified executor when the future completes.Constructor parameters in org.apache.ignite.internal.util.future with type arguments of type IgniteFuture Constructor Description AsyncFutureListener(IgniteInClosure<? super IgniteFuture<V>> lsnr, Executor exec) -
Uses of IgniteFuture in org.apache.ignite.internal.util.typedef
Method parameters in org.apache.ignite.internal.util.typedef with type arguments of type IgniteFuture Modifier and Type Method Description static voidX. waitAll(@Nullable Iterable<IgniteFuture<?>> futs)Synchronously waits for all futures in the collection. -
Uses of IgniteFuture in org.apache.ignite.lang
Methods in org.apache.ignite.lang that return IgniteFuture Modifier and Type Method 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.<T> IgniteFuture<T>IgniteFuture. chainAsync(IgniteClosure<? super IgniteFuture<V>,T> doneCb, Executor exec)Make a chained future to convert result of this future (when complete) into a new format.<R> IgniteFuture<R>IgniteAsyncSupport. future()Deprecated.since 2.0.Method parameters in org.apache.ignite.lang with type arguments of type IgniteFuture Modifier and Type Method 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.<T> IgniteFuture<T>IgniteFuture. chainAsync(IgniteClosure<? super IgniteFuture<V>,T> doneCb, Executor exec)Make a chained future to convert result of this future (when complete) into a new format.voidIgniteFuture. listen(IgniteInClosure<? super IgniteFuture<V>> lsnr)Registers a callback to be invoked when the future completes.voidIgniteFuture. listenAsync(IgniteInClosure<? super IgniteFuture<V>> lsnr, Executor exec)Registers a callback to be invoked with the specified executor when the future completes. -
Uses of IgniteFuture in org.apache.ignite.scheduler
Subinterfaces of IgniteFuture in org.apache.ignite.scheduler Modifier and Type Interface Description interfaceSchedulerFuture<R>Future for cron-based scheduled execution. -
Uses of IgniteFuture in org.apache.ignite.spi
Methods in org.apache.ignite.spi with parameters of type IgniteFuture Modifier and Type Method Description voidIgniteSpi. onClientDisconnected(IgniteFuture<?> reconnectFut)Client node disconnected callback.voidIgniteSpiAdapter. onClientDisconnected(IgniteFuture<?> reconnectFut)Client node disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.spi.communication.tcp
Methods in org.apache.ignite.spi.communication.tcp that return IgniteFuture Modifier and Type Method Description IgniteFuture<BitSet>TcpCommunicationSpi. checkConnection(List<ClusterNode> nodes)Methods in org.apache.ignite.spi.communication.tcp with parameters of type IgniteFuture Modifier and Type Method Description voidTcpCommunicationSpi. onClientDisconnected(IgniteFuture<?> reconnectFut)Client node disconnected callback. -
Uses of IgniteFuture in org.apache.ignite.spi.communication.tcp.internal
Methods in org.apache.ignite.spi.communication.tcp.internal with parameters of type IgniteFuture Modifier and Type Method Description voidConnectGateway. disconnected(IgniteFuture<?> reconnectFut) -
Uses of IgniteFuture in org.apache.ignite.spi.discovery
Methods in org.apache.ignite.spi.discovery that return IgniteFuture Modifier and Type Method Description IgniteFuture<?>DiscoverySpiListener. onDiscovery(DiscoveryNotification notification)Notification for grid node discovery events. -
Uses of IgniteFuture in org.apache.ignite.transactions
Methods in org.apache.ignite.transactions that return IgniteFuture Modifier and Type Method Description IgniteFuture<Void>Transaction. commitAsync()Asynchronously commits this transaction by initiatingtwo-phase-commitprocess.IgniteFuture<Void>Transaction. rollbackAsync()Asynchronously rolls back this transaction.
-