| Modifier and Type | Class and Description |
|---|---|
class |
ComputeTaskInternalFuture<R>
This class provide implementation for task future.
|
| Modifier and Type | Method and Description |
|---|---|
GridFutureAdapter<?> |
UnregisteredBinaryTypeException.future() |
@Nullable GridFutureAdapter<?> |
GridKernalGateway.onDisconnected()
Disconnected callback.
|
GridFutureAdapter<?> |
GridKernalGatewayImpl.onDisconnected()
Disconnected callback.
|
| Constructor and Description |
|---|
UnregisteredBinaryTypeException(int typeId,
GridFutureAdapter<?> fut) |
| Modifier and Type | Method and Description |
|---|---|
GridFutureAdapter<?> |
DistributedBaselineConfiguration.updateBaselineAutoAdjustEnabledAsync(boolean baselineAutoAdjustEnabled) |
GridFutureAdapter<?> |
DistributedBaselineConfiguration.updateBaselineAutoAdjustTimeoutAsync(long baselineAutoAdjustTimeout) |
| Modifier and Type | Method and Description |
|---|---|
GridFutureAdapter<DiscoveryLocalJoinData> |
GridDiscoveryManager.localJoinFuture() |
| Modifier and Type | Class and Description |
|---|---|
class |
CacheObjectsReleaseFuture<T,R> |
class |
GridCacheCompoundFuture<T,R> |
class |
GridCacheCompoundIdentityFuture<T> |
class |
GridCacheFutureAdapter<R> |
class |
GridCacheMultiTxFuture<K,V>
Future which waits for completion of one or more transactions.
|
| Modifier and Type | Method and Description |
|---|---|
GridFutureAdapter |
GridCacheMvccManager.addDataStreamerFuture(AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheProxyImpl.registrateFutureRestart(GridFutureAdapter<?> fut) |
void |
GridCacheProcessor.registrateProxyRestart(Map<String,DynamicCacheChangeRequest> reqs,
GridFutureAdapter<?> fut) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheTxRecoveryFuture
Future verifying that all remote transactions related to transaction were prepared or committed.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CacheDistributedGetFutureAdapter<K,V> |
protected class |
CacheDistributedGetFutureAdapter.AbstractMiniFuture
Mini-future for get operations.
|
class |
ClientCacheDhtTopologyFuture
Topology future created for client cache start.
|
class |
GridDhtAssignmentFetchFuture
Future that fetches affinity assignment from remote cache nodes.
|
class |
GridDhtEmbeddedFuture<A,B>
Embedded DHT future.
|
class |
GridDhtGetFuture<K,V> |
class |
GridDhtGetSingleFuture<K,V> |
class |
GridDhtLockFuture
Cache lock future.
|
class |
GridDhtTopologyFutureAdapter |
class |
GridDhtTxAbstractEnlistFuture<T>
Abstract future processing transaction enlisting and locking.
|
class |
GridDhtTxEnlistFuture
Future processing transaction enlisting and locking of entries produces by cache API operations.
|
class |
GridDhtTxFinishFuture<K,V> |
class |
GridDhtTxPrepareFuture |
class |
GridDhtTxQueryAbstractEnlistFuture
Abstract future processing transaction enlisting and locking of entries produced with DML and SELECT FOR UPDATE
queries.
|
class |
GridDhtTxQueryEnlistFuture
Cache query lock future.
|
class |
GridDhtTxQueryResultsEnlistFuture
Future processing transaction enlisting and locking of entries
produces by complex DML queries with reduce step.
|
class |
GridPartitionedGetFuture<K,V>
Colocated get future.
|
class |
GridPartitionedSingleGetFuture |
| Modifier and Type | Method and Description |
|---|---|
<T> GridFutureAdapter<T> |
GridDhtTxLocalAdapter.finishFuture(GridFutureAdapter<T> f,
Throwable err,
boolean clearLockFut) |
| Modifier and Type | Method and Description |
|---|---|
<T> GridFutureAdapter<T> |
GridDhtTxLocalAdapter.finishFuture(GridFutureAdapter<T> f,
Throwable err,
boolean clearLockFut) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtAtomicAbstractUpdateFuture
DHT atomic cache backup update future.
|
class |
GridNearAtomicAbstractUpdateFuture
Base for near atomic update futures.
|
class |
GridNearAtomicSingleUpdateFuture
DHT atomic cache near update future.
|
class |
GridNearAtomicUpdateFuture
DHT atomic cache near update future.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtColocatedLockFuture
Colocated cache lock future.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtForceKeysFuture<K,V>
Force keys request future.
|
static class |
GridDhtPartitionDemander.RebalanceFuture |
class |
GridDhtPartitionsExchangeFuture
Future for exchanging partition maps.
|
class |
InitNewCoordinatorFuture |
class |
StopCachesOnClientReconnectExchangeTask |
| Modifier and Type | Class and Description |
|---|---|
class |
GridNearGetFuture<K,V> |
class |
GridNearLockFuture
Cache lock future.
|
class |
GridNearOptimisticSerializableTxPrepareFuture |
class |
GridNearOptimisticTxPrepareFuture |
class |
GridNearOptimisticTxPrepareFutureAdapter |
protected static class |
GridNearOptimisticTxPrepareFutureAdapter.KeyLockFuture
Keys lock future.
|
class |
GridNearPessimisticTxPrepareFuture |
class |
GridNearTxAbstractEnlistFuture<T> |
class |
GridNearTxEnlistFuture
A future tracking requests for remote nodes transaction enlisting and locking produces by cache API operations.
|
class |
GridNearTxFastFinishFuture |
class |
GridNearTxFinishAndAckFuture |
class |
GridNearTxFinishFuture<K,V> |
class |
GridNearTxPrepareFutureAdapter
Common code for tx prepare in optimistic and pessimistic modes.
|
class |
GridNearTxQueryAbstractEnlistFuture |
class |
GridNearTxQueryEnlistFuture
Cache lock future.
|
class |
GridNearTxQueryResultsEnlistFuture
A future tracking requests for remote nodes transaction enlisting and locking
of entries produced with complex DML queries requiring reduce step.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNearReadRepairAbstractFuture |
class |
GridNearReadRepairCheckOnlyFuture
Checks data consistency.
|
class |
GridNearReadRepairFuture
Checks data consistency.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridLocalLockFuture<K,V>
Cache lock future.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MvccFuture<T> |
class |
MvccSnapshotFuture |
class |
VacuumTask
Task for cleaning sing partition.
|
| Modifier and Type | Method and Description |
|---|---|
GridFutureAdapter |
CheckpointProgressImpl.futureFor(CheckpointState state) |
GridFutureAdapter |
CheckpointProgress.futureFor(CheckpointState state) |
| Modifier and Type | Method and Description |
|---|---|
void |
FileUploader.upload(SocketChannel writeChan,
GridFutureAdapter<Long> finishFut) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheDistributedFieldsQueryFuture
Distributed fields query future.
|
class |
GridCacheDistributedQueryFuture<K,V,R>
Distributed query future.
|
class |
GridCacheLocalFieldsQueryFuture
Local fields query future.
|
class |
GridCacheLocalQueryFuture<K,V,R>
Local query future.
|
class |
GridCacheQueryFutureAdapter<K,V,R>
Query future adapter.
|
static class |
GridCacheQueryManager.QueryResult<K,V> |
| Modifier and Type | Method and Description |
|---|---|
GridFutureAdapter<GridCacheQueryManager.QueryResult<K,V>> |
GridCacheQueryManager.RequestFutureMap.remove(Object key) |
| Modifier and Type | Class and Description |
|---|---|
class |
PartitionCountersNeighborcastFuture
Represents partition update counters delivery to remote nodes.
|
| Modifier and Type | Method and Description |
|---|---|
GridDhtTopologyFuture |
IgniteTxStateImpl.topologyReadLock(GridCacheSharedContext cctx,
GridFutureAdapter<?> fut) |
GridDhtTopologyFuture |
IgniteTxImplicitSingleStateImpl.topologyReadLock(GridCacheSharedContext cctx,
GridFutureAdapter<?> fut) |
GridDhtTopologyFuture |
IgniteTxState.topologyReadLock(GridCacheSharedContext cctx,
GridFutureAdapter<?> fut) |
GridDhtTopologyFuture |
IgniteTxRemoteStateAdapter.topologyReadLock(GridCacheSharedContext cctx,
GridFutureAdapter<?> fut) |
| Modifier and Type | Method and Description |
|---|---|
GridFutureAdapter<?> |
PropertyUpdateClosure.casUpdate(String key,
Serializable expectedValue,
Serializable newValue)
Update property on cluster using compare and set way.
|
GridFutureAdapter<?> |
DistributedProperty.propagateAsync(T newVal)
Change value across whole cluster.
|
GridFutureAdapter<?> |
SimpleDistributedProperty.propagateAsync(T newVal)
Change value across whole cluster.
|
GridFutureAdapter<?> |
DistributedProperty.propagateAsync(T expectedVal,
T newVal)
Change value across whole cluster.
|
GridFutureAdapter<?> |
SimpleDistributedProperty.propagateAsync(T expectedVal,
T newVal)
Change value across whole cluster.
|
GridFutureAdapter<?> |
PropertyUpdateClosure.update(String key,
Serializable newValue)
Update property on cluster.
|
| Modifier and Type | Method and Description |
|---|---|
GridFutureAdapter<MappingExchangeResult> |
MarshallerMappingTransport.awaitMappingAcceptance(MarshallerMappingItem item,
ConcurrentMap<Integer,MappedName> cache) |
GridFutureAdapter<MappingExchangeResult> |
MarshallerMappingTransport.proposeMapping(MarshallerMappingItem item,
ConcurrentMap<Integer,MappedName> cache) |
GridFutureAdapter<MappingExchangeResult> |
MarshallerMappingTransport.requestMapping(MarshallerMappingItem item,
ConcurrentMap<Integer,MappedName> cache) |
| Modifier and Type | Method and Description |
|---|---|
GridFutureAdapter<Boolean> |
DistributedMetaStorage.compareAndSetAsync(@NotNull String key,
@Nullable Serializable expVal,
@NotNull Serializable newVal)
Write value into distributed metastorage asynchronously but only if current value matches the expected one.
|
GridFutureAdapter<?> |
DistributedMetaStorage.removeAsync(@NotNull String key)
Remove value from distributed metastorage asynchronously.
|
GridFutureAdapter<?> |
DistributedMetaStorage.writeAsync(@NotNull String key,
@NotNull Serializable val)
Write value into distributed metastorage asynchronously.
|
| Modifier and Type | Method and Description |
|---|---|
GridFutureAdapter<Boolean> |
DistributedMetaStorageImpl.compareAndSetAsync(@NotNull String key,
@Nullable Serializable expVal,
@NotNull Serializable newVal)
Write value into distributed metastorage asynchronously but only if current value matches the expected one.
|
GridFutureAdapter<?> |
DistributedMetaStorageImpl.removeAsync(@NotNull String key)
Remove value from distributed metastorage asynchronously.
|
GridFutureAdapter<?> |
DistributedMetaStorageImpl.writeAsync(@NotNull String key,
@NotNull Serializable val)
Write value into distributed metastorage asynchronously.
|
| Modifier and Type | Class and Description |
|---|---|
class |
QueryRunningFuture
Query running future.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SchemaOperationClientFuture
Schema operation client future.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridFutureAdapter<Void> |
SchemaIndexCacheVisitorImpl.buildIdxFut
Future for create/rebuild index.
|
| Constructor and Description |
|---|
SchemaIndexCachePartitionWorker(GridCacheContext cctx,
GridDhtLocalPartition locPart,
AtomicBoolean stop,
SchemaIndexOperationCancellationToken cancel,
SchemaIndexCacheVisitorClosure clo,
GridFutureAdapter<SchemaIndexCacheStat> fut,
AtomicInteger partsCnt)
Constructor.
|
SchemaIndexCacheVisitorImpl(GridCacheContext cctx,
@Nullable SchemaIndexOperationCancellationToken cancel,
GridFutureAdapter<Void> buildIdxFut)
Constructor.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridServiceDeploymentCompoundFuture<T extends Serializable>
Service deployment compound future.
|
class |
GridServiceDeploymentFuture<T extends Serializable>
Service deployment future.
|
| Modifier and Type | Method and Description |
|---|---|
static Runnable |
IgniteUtils.wrapIgniteFuture(Runnable r,
GridFutureAdapter<?> fut) |
| Modifier and Type | Class and Description |
|---|---|
class |
CountDownFuture |
class |
GridCompoundFuture<T,R>
Future composed of multiple inner futures.
|
class |
GridCompoundIdentityFuture<T>
Compound future with reducer which accepts and produces results of the same type.
|
class |
GridEmbeddedFuture<A,B>
Future which waits for embedded future to complete and then asynchronously executes
provided closure with embedded future result.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNioEmbeddedFuture<R>
Future that delegates to some other future.
|
class |
GridNioFutureImpl<R>
Default future implementation.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridWorkerFuture<T>
Future for locally executed closure that defines cancellation logic.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ConnectionRequestFuture
Marker future implementation, just like
ConnectFuture, but meaning that we're waiting for the inverse
connection. |
class |
TcpCommunicationConnectionCheckFuture
Tcp Communication Connection Check Future.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FutureTask<T> |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.1 Release Date : December 9 2020