| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<?> |
GridCache.forceRepartition()
Forces this cache node to re-balance its partitions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ComputeTaskInternalFuture<R>
This class provide implementation for task future.
|
| Modifier and Type | Method and Description |
|---|---|
<T> IgniteInternalFuture<T> |
IgniteInternalFuture.chain(IgniteClosure<? super IgniteInternalFuture<R>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
| Modifier and Type | Method and Description |
|---|---|
protected <R> IgniteFuture<R> |
AsyncSupportAdapter.createFuture(IgniteInternalFuture<R> fut) |
protected <R> IgniteFuture<R> |
IgniteComputeImpl.createFuture(IgniteInternalFuture<R> fut) |
<R> R |
AsyncSupportAdapter.saveOrGet(IgniteInternalFuture<R> fut) |
| Modifier and Type | Method and Description |
|---|---|
<T> IgniteInternalFuture<T> |
IgniteInternalFuture.chain(IgniteClosure<? super IgniteInternalFuture<R>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
void |
IgniteInternalFuture.listen(IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Long> |
GridDiscoveryManager.topologyFuture(long awaitVer)
Gets future that will be completed when current topology version becomes greater or equal to argument passed.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Event> |
GridEventStorageManager.remoteEventsAsync(IgnitePredicate<T> p,
Collection<? extends ClusterNode> nodes,
long timeout) |
<T extends Event> |
GridEventStorageManager.waitForEvent(IgnitePredicate<T> p,
int... types) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Long> |
GridAffinityAssignmentCache.readyFuture(long topVer)
Gets future that will be completed after topology with version
topVer is calculated. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
GridCacheAtomicFuture<R>
Update future for atomic cache.
|
interface |
GridCacheFuture<R>
This interface should be implemented by all distributed futures.
|
interface |
GridCacheMvccFuture<T>
Distributed future aware of MVCC locking.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheMultiTxFuture<K,V>
Future which waits for completion of one or more transactions.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Long> |
GridCacheAffinityManager.affinityReadyFuture(long topVer)
Gets affinity ready future, a future that will be completed after affinity with given
topology version is calculated.
|
IgniteInternalFuture<Long> |
GridCacheAffinityManager.affinityReadyFuturex(long topVer)
Gets affinity ready future that will be completed after affinity with given topology version is calculated.
|
protected <T> IgniteInternalFuture<T> |
GridCacheAdapter.asyncOp(IgniteTxLocalAdapter tx,
GridCacheAdapter.AsyncOp<T> op) |
protected <T> IgniteInternalFuture<T> |
GridCacheAdapter.asyncOpAcquire()
Tries to acquire asynchronous operations permit, if limited.
|
IgniteInternalFuture<?> |
GridCacheMvccManager.atomicFuture(GridCacheVersion futVer)
Gets future by given future ID.
|
IgniteInternalFuture<?> |
CacheProjection.clearAsync() |
IgniteInternalFuture<?> |
GridCacheProjectionImpl.clearAsync() |
IgniteInternalFuture<?> |
GridCacheProxyImpl.clearAsync() |
IgniteInternalFuture<?> |
GridCacheAdapter.clearAsync() |
IgniteInternalFuture<?> |
CacheProjection.clearAsync(K key) |
IgniteInternalFuture<?> |
GridCacheProjectionImpl.clearAsync(K key) |
IgniteInternalFuture<?> |
GridCacheProxyImpl.clearAsync(K key) |
IgniteInternalFuture<?> |
GridCacheAdapter.clearAsync(K key) |
IgniteInternalFuture<?> |
CacheProjection.clearAsync(Set<K> keys) |
IgniteInternalFuture<?> |
GridCacheProjectionImpl.clearAsync(Set<K> keys) |
IgniteInternalFuture<?> |
GridCacheProxyImpl.clearAsync(Set<K> keys) |
IgniteInternalFuture<?> |
GridCacheAdapter.clearAsync(Set<K> keys) |
IgniteInternalFuture<IgniteInternalTx> |
GridCacheSharedContext.commitTxAsync(IgniteInternalTx tx) |
IgniteInternalFuture<IgniteInternalTx> |
GridCacheAdapter.commitTxAsync(IgniteInternalTx tx)
Asynchronously commits transaction after all previous asynchronous operations are completed.
|
IgniteInternalFuture<Boolean> |
CacheProjection.containsKeyAsync(K key) |
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.containsKeyAsync(K key) |
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.containsKeyAsync(K key) |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.containsKeyAsync(K key) |
IgniteInternalFuture<Boolean> |
CacheProjection.containsKeysAsync(Collection<? extends K> keys) |
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.containsKeysAsync(Collection<? extends K> keys) |
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.containsKeysAsync(Collection<? extends K> keys) |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.containsKeysAsync(Collection<? extends K> keys) |
IgniteInternalFuture<?> |
GridCacheMvccManager.finishAtomicUpdates(long topVer) |
IgniteInternalFuture<?> |
GridCacheMvccManager.finishExplicitLocks(long topVer)
Creates a future that will wait for all explicit locks acquired on given topology
version to be released.
|
IgniteInternalFuture<?> |
GridCacheMvccManager.finishKeys(Collection<KeyCacheObject> keys,
long topVer) |
IgniteInternalFuture<?> |
GridCacheMvccManager.finishLocks(long topVer) |
IgniteInternalFuture<?> |
GridCacheProxyImpl.forceRepartition()
Forces this cache node to re-balance its partitions.
|
IgniteInternalFuture<?> |
GridCacheAdapter.forceRepartition()
Forces this cache node to re-balance its partitions.
|
IgniteInternalFuture |
GridCacheAdapter.FutureHolder.future()
Gets future.
|
IgniteInternalFuture<Map<K,V>> |
CacheProjection.getAllAsync(Collection<? extends K> keys)
Asynchronously retrieves values mapped to the specified keys from cache.
|
IgniteInternalFuture<Map<K,V>> |
GridCacheProjectionImpl.getAllAsync(Collection<? extends K> keys)
Asynchronously retrieves values mapped to the specified keys from cache.
|
IgniteInternalFuture<Map<K,V>> |
GridCacheProxyImpl.getAllAsync(Collection<? extends K> keys)
Asynchronously retrieves values mapped to the specified keys from cache.
|
IgniteInternalFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys)
Asynchronously retrieves values mapped to the specified keys from cache.
|
IgniteInternalFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean deserializePortable) |
protected IgniteInternalFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals) |
IgniteInternalFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean readThrough,
GridCacheEntryEx cached,
boolean checkTx,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean forcePrimary,
IgniteCacheExpiryPolicy expiry,
boolean skipVals) |
<K1,V1> IgniteInternalFuture<Map<K1,V1>> |
GridCacheAdapter.getAllAsync0(Collection<KeyCacheObject> keys,
boolean readThrough,
boolean checkTx,
UUID subjId,
String taskName,
boolean deserializePortable,
IgniteCacheExpiryPolicy expiry,
boolean skipVals,
boolean keepCacheObjects) |
IgniteInternalFuture<Map<K,V>> |
GridCacheProjectionImpl.getAllOutTxAsync(List<K> keys)
Asynchronously gets values from cache.
|
IgniteInternalFuture<Map<K,V>> |
GridCacheProjectionEx.getAllOutTxAsync(List<K> keys)
Asynchronously gets values from cache.
|
IgniteInternalFuture<Map<K,V>> |
GridCacheProxyImpl.getAllOutTxAsync(List<K> keys)
Asynchronously gets values from cache.
|
IgniteInternalFuture<Map<K,V>> |
GridCacheAdapter.getAllOutTxAsync(List<K> keys)
Asynchronously gets values from cache.
|
IgniteInternalFuture<V> |
CacheProjection.getAsync(K key)
Asynchronously retrieves value mapped to the specified key from cache.
|
IgniteInternalFuture<V> |
GridCacheProjectionImpl.getAsync(K key)
Asynchronously retrieves value mapped to the specified key from cache.
|
IgniteInternalFuture<V> |
GridCacheProxyImpl.getAsync(K key)
Asynchronously retrieves value mapped to the specified key from cache.
|
IgniteInternalFuture<V> |
GridCacheAdapter.getAsync(K key)
Asynchronously retrieves value mapped to the specified key from cache.
|
IgniteInternalFuture<V> |
GridCacheAdapter.getAsync(K key,
boolean deserializePortable) |
IgniteInternalFuture<V> |
GridCacheProjectionImpl.getForcePrimaryAsync(K key)
Asynchronously gets value from cache.
|
IgniteInternalFuture<V> |
GridCacheProjectionEx.getForcePrimaryAsync(K key)
Asynchronously gets value from cache.
|
IgniteInternalFuture<V> |
GridCacheProxyImpl.getForcePrimaryAsync(K key)
Asynchronously gets value from cache.
|
IgniteInternalFuture<V> |
GridCacheAdapter.getForcePrimaryAsync(K key)
Asynchronously gets value from cache.
|
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridCacheProjectionImpl.invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridCacheProjectionEx.invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridCacheProxyImpl.invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridCacheAdapter.invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridCacheProjectionImpl.invokeAllAsync(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridCacheProjectionEx.invokeAllAsync(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridCacheProxyImpl.invokeAllAsync(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridCacheAdapter.invokeAllAsync(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>> |
GridCacheProjectionImpl.invokeAsync(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>> |
GridCacheProjectionEx.invokeAsync(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>> |
GridCacheProxyImpl.invokeAsync(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>> |
GridCacheAdapter.invokeAsync(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
IgniteInternalFuture<?> |
GridCacheAdapter.loadAll(Set<? extends K> keys,
boolean replaceExisting) |
IgniteInternalFuture<?> |
GridCacheProjectionImpl.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
IgniteInternalFuture<?> |
GridCacheProjectionEx.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
IgniteInternalFuture<?> |
GridCacheProxyImpl.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object[] args)
Asynchronously delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
IgniteInternalFuture<?> |
GridCacheAdapter.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object[] args)
Asynchronously delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
IgniteInternalFuture<?> |
GridCacheAdapter.localRemoveAll(CacheEntryPredicate filter) |
IgniteInternalFuture<Boolean> |
CacheProjection.lockAllAsync(Collection<? extends K> keys,
long timeout,
CacheEntryPredicate... filter)
All or nothing synchronous lock for passed in keys.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.lockAllAsync(Collection<? extends K> keys,
long timeout,
CacheEntryPredicate[] filter)
All or nothing synchronous lock for passed in keys.
|
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.lockAllAsync(Collection<? extends K> keys,
long timeout,
CacheEntryPredicate[] filter)
All or nothing synchronous lock for passed in keys.
|
IgniteInternalFuture<Boolean> |
CacheProjection.lockAsync(K key,
long timeout,
CacheEntryPredicate... filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
IgniteInternalFuture<Boolean> |
GridCacheAdapter.lockAsync(K key,
long timeout,
CacheEntryPredicate... filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.lockAsync(K key,
long timeout,
CacheEntryPredicate[] filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.lockAsync(K key,
long timeout,
CacheEntryPredicate[] filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
abstract IgniteInternalFuture<T> |
GridCacheAdapter.AsyncOp.op(IgniteTxLocalAdapter tx) |
IgniteInternalFuture<?> |
GridCacheProcessor.orderedPreloadFuture(int order)
Gets preload finish future for preload-ordered cache with given order.
|
IgniteInternalFuture<?> |
GridCacheSharedContext.partitionReleaseFuture(long topVer)
Waits for partition locks and transactions release.
|
IgniteInternalFuture<Object> |
GridCacheSharedContext.preloadersStartFuture() |
IgniteInternalFuture<?> |
CacheProjection.putAllAsync(Map<? extends K,? extends V> m,
CacheEntryPredicate... filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
GridCacheAdapter.putAllAsync(Map<? extends K,? extends V> m,
CacheEntryPredicate... filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
GridCacheProjectionImpl.putAllAsync(Map<? extends K,? extends V> m,
CacheEntryPredicate[] filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.putAllAsync(Map<? extends K,? extends V> m,
CacheEntryPredicate[] filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
GridCacheProjectionImpl.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheProjectionEx.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheAdapter.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<V> |
CacheProjection.putAsync(K key,
V val,
CacheEntryPredicate... filter)
Asynchronously stores given key-value pair in cache.
|
IgniteInternalFuture<V> |
GridCacheProjectionImpl.putAsync(K key,
V val,
CacheEntryPredicate[] filter)
Asynchronously stores given key-value pair in cache.
|
IgniteInternalFuture<V> |
GridCacheProxyImpl.putAsync(K key,
V val,
CacheEntryPredicate[] filter)
Asynchronously stores given key-value pair in cache.
|
IgniteInternalFuture<V> |
GridCacheAdapter.putAsync(K key,
V val,
CacheEntryPredicate[] filter)
Asynchronously stores given key-value pair in cache.
|
IgniteInternalFuture<V> |
GridCacheProjectionEx.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProxyImpl.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheAdapter.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProjectionImpl.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate[] filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
CacheProjection.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<V> |
GridCacheProjectionImpl.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<V> |
GridCacheProxyImpl.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<V> |
GridCacheAdapter.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<Boolean> |
CacheProjection.putxAsync(K key,
V val,
CacheEntryPredicate... filter)
Stores given key-value pair in cache.
|
IgniteInternalFuture<Boolean> |
GridCacheAdapter.putxAsync(K key,
V val,
CacheEntryPredicate... filter)
Stores given key-value pair in cache.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.putxAsync(K key,
V val,
CacheEntryPredicate[] filter)
Stores given key-value pair in cache.
|
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.putxAsync(K key,
V val,
CacheEntryPredicate[] filter)
Stores given key-value pair in cache.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionEx.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate[] filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
CacheProjection.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<Boolean> |
GridCacheAdapter.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<Object> |
GridCacheAdapter.readThroughAllAsync(Collection<KeyCacheObject> keys,
boolean reload,
boolean skipVals,
IgniteInternalTx tx,
UUID subjId,
String taskName,
IgniteBiInClosure<KeyCacheObject,Object> vis) |
IgniteInternalFuture<Object> |
GridCacheExplicitLockSpan.releaseFuture()
Gets span release future.
|
IgniteInternalFuture<Map<KeyCacheObject,CacheObject>> |
GridCacheAdapter.reloadAllAsync0(Collection<KeyCacheObject> keys,
boolean ret,
boolean skipVals,
UUID subjId,
String taskName) |
IgniteInternalFuture<V> |
CacheProjection.reloadAsync(K key)
Asynchronously reloads a single key from persistent storage.
|
IgniteInternalFuture<V> |
GridCacheProjectionImpl.reloadAsync(K key)
Asynchronously reloads a single key from persistent storage.
|
IgniteInternalFuture<V> |
GridCacheProxyImpl.reloadAsync(K key)
Asynchronously reloads a single key from persistent storage.
|
IgniteInternalFuture<V> |
GridCacheAdapter.reloadAsync(K key) |
IgniteInternalFuture<?> |
CacheProjection.removeAllAsync() |
IgniteInternalFuture<?> |
GridCacheProjectionImpl.removeAllAsync() |
IgniteInternalFuture<?> |
GridCacheProxyImpl.removeAllAsync() |
IgniteInternalFuture<?> |
CacheProjection.removeAllAsync(Collection<? extends K> keys,
CacheEntryPredicate... filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<?> |
GridCacheAdapter.removeAllAsync(Collection<? extends K> keys,
CacheEntryPredicate... filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<?> |
GridCacheProjectionImpl.removeAllAsync(Collection<? extends K> keys,
CacheEntryPredicate[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.removeAllAsync(Collection<? extends K> keys,
CacheEntryPredicate[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<?> |
GridCacheProjectionImpl.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheProjectionEx.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheAdapter.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<V> |
CacheProjection.removeAsync(K key,
CacheEntryPredicate... filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<V> |
GridCacheAdapter.removeAsync(K key,
CacheEntryPredicate... filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<V> |
GridCacheProjectionImpl.removeAsync(K key,
CacheEntryPredicate[] filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<V> |
GridCacheProxyImpl.removeAsync(K key,
CacheEntryPredicate[] filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<V> |
GridCacheProjectionImpl.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProjectionEx.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProxyImpl.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheAdapter.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
CacheProjection.removeAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.removeAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.removeAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<Boolean> |
GridCacheAdapter.removeAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<?> |
GridCacheMvccManager.removeAtomicFuture(GridCacheVersion futVer) |
IgniteInternalFuture<Boolean> |
CacheProjection.removexAsync(K key,
CacheEntryPredicate... filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<Boolean> |
GridCacheAdapter.removexAsync(K key,
CacheEntryPredicate... filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.removexAsync(K key,
CacheEntryPredicate[] filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.removexAsync(K key,
CacheEntryPredicate[] filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProjectionEx.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<GridCacheReturn> |
GridCacheProjectionImpl.removexAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<GridCacheReturn> |
GridCacheProjectionEx.removexAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<GridCacheReturn> |
GridCacheProxyImpl.removexAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<GridCacheReturn> |
GridCacheAdapter.removexAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<V> |
CacheProjection.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if there is a previous mapping for it.
|
IgniteInternalFuture<V> |
GridCacheProjectionImpl.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if there is a previous mapping for it.
|
IgniteInternalFuture<V> |
GridCacheProxyImpl.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if there is a previous mapping for it.
|
IgniteInternalFuture<V> |
GridCacheAdapter.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if there is a previous mapping for it.
|
IgniteInternalFuture<Boolean> |
CacheProjection.replaceAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.replaceAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.replaceAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.replaceAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<Boolean> |
CacheProjection.replacexAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if only if there is a previous mapping for it.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.replacexAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if only if there is a previous mapping for it.
|
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.replacexAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if only if there is a previous mapping for it.
|
IgniteInternalFuture<Boolean> |
GridCacheAdapter.replacexAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if only if there is a previous mapping for it.
|
IgniteInternalFuture<GridCacheReturn> |
GridCacheProjectionImpl.replacexAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<GridCacheReturn> |
GridCacheProjectionEx.replacexAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<GridCacheReturn> |
GridCacheProxyImpl.replacexAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<GridCacheReturn> |
GridCacheAdapter.replacexAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<Object> |
GridCachePreloader.request(Collection<KeyCacheObject> keys,
long topVer)
Requests that preloader sends the request for the key.
|
IgniteInternalFuture<Object> |
GridCachePreloaderAdapter.request(Collection<KeyCacheObject> keys,
long topVer)
Requests that preloader sends the request for the key.
|
IgniteInternalFuture |
GridCacheSharedContext.rollbackTxAsync(IgniteInternalTx tx) |
IgniteInternalFuture<Integer> |
CacheProjection.sizeAsync(CachePeekMode[] peekModes) |
IgniteInternalFuture<Integer> |
GridCacheProjectionImpl.sizeAsync(CachePeekMode[] peekModes) |
IgniteInternalFuture<Integer> |
GridCacheProxyImpl.sizeAsync(CachePeekMode[] peekModes) |
IgniteInternalFuture<Integer> |
GridCacheAdapter.sizeAsync(CachePeekMode[] peekModes) |
IgniteInternalFuture<Object> |
GridCachePreloader.startFuture() |
IgniteInternalFuture<Object> |
GridCachePreloaderAdapter.startFuture() |
IgniteInternalFuture<?> |
GridCachePreloader.syncFuture() |
IgniteInternalFuture<?> |
GridCachePreloaderAdapter.syncFuture() |
abstract IgniteInternalFuture<Boolean> |
GridCacheAdapter.txLockAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean invalidate,
long accessTtl,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<V> |
GridCacheContext.wrapClone(IgniteInternalFuture<V> f) |
| Modifier and Type | Method and Description |
|---|---|
static IgniteInClosure<IgniteInternalFuture<?>> |
GridCacheUtils.errorLogger(IgniteLogger log,
Class<? extends Exception>... excl) |
List<IgniteInternalFuture<?>> |
GridCachePartitionExchangeManager.exchangeFutures() |
<T> Collection<? extends IgniteInternalFuture<T>> |
GridCacheMvccManager.futures(GridCacheVersion ver)
Gets all futures for given lock version, possibly empty collection.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheAdapter.UpdateTimeStatClosure.apply(IgniteInternalFuture<T> fut)
Closure body.
|
void |
GridCacheAdapter.FutureHolder.future(IgniteInternalFuture fut)
Sets future.
|
protected void |
GridCacheAdapter.saveFuture(GridCacheAdapter.FutureHolder holder,
IgniteInternalFuture<?> fut)
Saves future in thread local holder and adds listener
that will clear holder when future is finished.
|
IgniteInternalFuture<V> |
GridCacheContext.wrapClone(IgniteInternalFuture<V> f) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheOptimisticCheckPreparedTxFuture<K,V>
Future verifying that all remote transactions related to some
optimistic transaction were prepared.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<?> |
GridCacheTxFinishSync.awaitAckAsync(UUID nodeId,
long threadId) |
IgniteInternalFuture<IgniteInternalTx> |
GridDistributedTxRemoteAdapter.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
IgniteInternalFuture<Boolean> |
GridDistributedCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
CacheEntryPredicate... filter)
All or nothing synchronous lock for passed in keys.
|
protected abstract IgniteInternalFuture<Boolean> |
GridDistributedCacheAdapter.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<IgniteInternalTx> |
GridDistributedTxRemoteAdapter.prepareAsync()
Prepare stage.
|
IgniteInternalFuture<?> |
GridDistributedCacheAdapter.removeAllAsync() |
IgniteInternalFuture<IgniteInternalTx> |
GridDistributedTxRemoteAdapter.rollbackAsync()
Asynchronously rollback this transaction.
|
IgniteInternalFuture<Boolean> |
GridDistributedCacheAdapter.txLockAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean isInvalidate,
long accessTtl,
CacheEntryPredicate[] filter) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
GridDhtFuture<T>
Keys to retry.
|
interface |
GridDhtTopologyFuture
Future that implements a barrier after which dht topology is safe to use.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtAssignmentFetchFuture
Future that fetches affinity assignment from remote cache nodes.
|
class |
GridDhtEmbeddedFuture<A,B>
Embedded DHT future.
|
class |
GridDhtFinishedFuture<T>
Finished DHT future.
|
class |
GridDhtGetFuture<K,V> |
class |
GridDhtLockFuture<K,V>
Cache lock future.
|
class |
GridDhtTxFinishFuture<K,V> |
class |
GridDhtTxPrepareFuture<K,V> |
class |
GridPartitionedGetFuture<K,V>
Colocated get future.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridDhtTxLocalAdapter.addEntry(long msgId,
IgniteTxEntry e) |
protected IgniteInternalFuture<Boolean> |
GridDhtTxLocal.addReader(long msgId,
GridDhtCacheEntry cached,
IgniteTxEntry entry,
long topVer)
Adds reader to cached entry.
|
protected abstract IgniteInternalFuture<Boolean> |
GridDhtTxLocalAdapter.addReader(long msgId,
GridDhtCacheEntry cached,
IgniteTxEntry entry,
long topVer)
Adds reader to cached entry.
|
IgniteInternalFuture<Boolean> |
GridDhtCacheEntry.addReader(UUID nodeId,
long msgId,
long topVer) |
IgniteInternalFuture<IgniteInternalTx> |
GridDhtTxLocal.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
IgniteInternalFuture<Map<K,V>> |
GridDhtCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals)
This method is used internally.
|
IgniteInternalFuture<Boolean> |
GridDhtTransactionalCacheAdapter.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx txx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<GridNearLockResponse> |
GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<K,V> cacheCtx,
ClusterNode nearNode,
GridNearLockRequest req,
CacheEntryPredicate[] filter0) |
IgniteInternalFuture<?> |
GridDhtCacheAdapter.multiUpdateFinishFuture(long topVer)
Creates multi update finish future.
|
IgniteInternalFuture<IgniteInternalTx> |
GridDhtTxLocal.prepareAsync()
Prepare stage.
|
IgniteInternalFuture<IgniteInternalTx> |
GridDhtTxLocal.prepareAsync(Iterable<IgniteTxEntry> reads,
Iterable<IgniteTxEntry> writes,
Map<IgniteTxKey,GridCacheVersion> verMap,
long msgId,
IgniteUuid nearMiniId,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
Collection<UUID> lastBackups,
IgniteInClosure<GridNearTxPrepareResponse> completeCb)
Prepares next batch of entries in dht transaction.
|
IgniteInternalFuture<IgniteInternalTx> |
GridDhtTxLocal.rollbackAsync()
Asynchronously rollback this transaction.
|
| Constructor and Description |
|---|
GridDhtEmbeddedFuture(IgniteBiClosure<B,Exception,A> c,
IgniteInternalFuture<B> embedded) |
GridDhtEmbeddedFuture(IgniteInternalFuture<B> embedded,
IgniteBiClosure<B,Exception,IgniteInternalFuture<A>> c) |
| Constructor and Description |
|---|
GridDhtEmbeddedFuture(IgniteInternalFuture<B> embedded,
IgniteBiClosure<B,Exception,IgniteInternalFuture<A>> c) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtAtomicUpdateFuture
DHT atomic cache backup update future.
|
class |
GridNearAtomicUpdateFuture
DHT atomic cache near update future.
|
| Modifier and Type | Method and Description |
|---|---|
protected <T> IgniteInternalFuture<T> |
GridDhtAtomicCache.asyncOp(CO<IgniteInternalFuture<T>> op) |
IgniteInternalFuture<Map<K,V>> |
GridDhtAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals)
This method is used internally.
|
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridDhtAtomicCache.invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridDhtAtomicCache.invokeAllAsync(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>> |
GridDhtAtomicCache.invokeAsync(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
IgniteInternalFuture<?> |
GridDhtAtomicCache.localRemoveAll(CacheEntryPredicate filter) |
protected IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<?> |
GridDhtAtomicCache.putAllAsync(Map<? extends K,? extends V> m,
CacheEntryPredicate[] filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
GridDhtAtomicCache.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> conflictMap)
Store DR data asynchronously.
|
IgniteInternalFuture<V> |
GridDhtAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridDhtAtomicCache.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<?> |
GridDhtAtomicCache.removeAllAsync(Collection<? extends K> keys,
CacheEntryPredicate[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<?> |
GridDhtAtomicCache.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> conflictMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<V> |
GridDhtAtomicCache.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.removeAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<GridCacheReturn> |
GridDhtAtomicCache.removexAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<V> |
GridDhtAtomicCache.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if there is a previous mapping for it.
|
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.replaceAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.replacexAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if only if there is a previous mapping for it.
|
IgniteInternalFuture<GridCacheReturn> |
GridDhtAtomicCache.replacexAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
| Modifier and Type | Method and Description |
|---|---|
protected <T> IgniteInternalFuture<T> |
GridDhtAtomicCache.asyncOp(CO<IgniteInternalFuture<T>> op) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtColocatedLockFuture<K,V>
Colocated cache lock future.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridDhtColocatedCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals)
This method is used internally.
|
IgniteInternalFuture<Map<K,V>> |
GridDhtColocatedCache.loadAsync(Collection<KeyCacheObject> keys,
boolean readThrough,
boolean reload,
boolean forcePrimary,
long topVer,
UUID subjId,
String taskName,
boolean deserializePortable,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals) |
IgniteInternalFuture<Boolean> |
GridDhtColocatedCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
CacheEntryPredicate[] filter)
This is an entry point to pessimistic locking within transaction.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtForceKeysFuture<K,V>
Force keys request future.
|
class |
GridDhtPartitionsExchangeFuture
Future for exchanging partition maps.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Object> |
GridDhtPreloader.startFuture() |
IgniteInternalFuture<?> |
GridDhtPreloader.syncFuture() |
| Modifier and Type | Class and Description |
|---|---|
class |
GridNearGetFuture<K,V> |
class |
GridNearLockFuture<K,V>
Cache lock future.
|
class |
GridNearTxFinishFuture<K,V> |
class |
GridNearTxPrepareFuture<K,V> |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteInternalFuture<Boolean> |
GridNearTxLocal.addReader(long msgId,
GridDhtCacheEntry cached,
IgniteTxEntry entry,
long topVer)
Adds reader to cached entry.
|
IgniteInternalFuture<IgniteInternalTx> |
GridNearTxLocal.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
IgniteInternalFuture<IgniteInternalTx> |
GridNearTxLocal.commitAsyncLocal()
Commits local part of colocated transaction.
|
protected IgniteInternalFuture<Map<K,V>> |
GridNearAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals) |
IgniteInternalFuture<Map<K,V>> |
GridNearTransactionalCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridNearAtomicCache.invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridNearAtomicCache.invokeAllAsync(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>> |
GridNearAtomicCache.invokeAsync(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
IgniteInternalFuture<Map<K,V>> |
GridNearCacheAdapter.loadAsync(IgniteInternalTx tx,
Collection<KeyCacheObject> keys,
boolean reload,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializePortable,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean skipVal) |
IgniteInternalFuture<Boolean> |
GridNearTxLocal.loadMissing(GridCacheContext cacheCtx,
boolean readThrough,
boolean async,
Collection<KeyCacheObject> keys,
boolean deserializePortable,
boolean skipVals,
IgniteBiInClosure<KeyCacheObject,Object> c) |
IgniteInternalFuture<?> |
GridNearCacheAdapter.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object[] args)
Asynchronously delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
IgniteInternalFuture<?> |
GridNearAtomicCache.localRemoveAll(CacheEntryPredicate filter) |
protected IgniteInternalFuture<Boolean> |
GridNearAtomicCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
CacheEntryPredicate[] filter) |
protected IgniteInternalFuture<Boolean> |
GridNearTransactionalCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
CacheEntryPredicate[] filter) |
<K> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.lockAllAsync(GridCacheContext cacheCtx,
Collection<? extends K> keys,
boolean implicit,
boolean read,
long accessTtl) |
IgniteInternalFuture<IgniteInternalTx> |
GridNearTxLocal.prepareAsync()
Prepare stage.
|
IgniteInternalFuture<IgniteInternalTx> |
GridNearTxLocal.prepareAsyncLocal(Collection<IgniteTxEntry> reads,
Collection<IgniteTxEntry> writes,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
Collection<UUID> lastBackups,
IgniteInClosure<GridNearTxPrepareResponse> completeCb)
Prepares next batch of entries in dht transaction.
|
IgniteInternalFuture<?> |
GridNearAtomicCache.putAllAsync(Map<? extends K,? extends V> m,
CacheEntryPredicate[] filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
GridNearAtomicCache.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<V> |
GridNearAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridNearAtomicCache.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<Object> |
GridNearCacheAdapter.readThroughAllAsync(Collection<KeyCacheObject> keys,
boolean reload,
boolean skipVals,
IgniteInternalTx tx,
UUID subjId,
String taskName,
IgniteBiInClosure<KeyCacheObject,Object> vis) |
IgniteInternalFuture<?> |
GridNearAtomicCache.removeAllAsync() |
IgniteInternalFuture<?> |
GridNearAtomicCache.removeAllAsync(Collection<? extends K> keys,
CacheEntryPredicate[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<?> |
GridNearAtomicCache.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<V> |
GridNearAtomicCache.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.removeAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<GridCacheReturn> |
GridNearAtomicCache.removexAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<V> |
GridNearAtomicCache.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if there is a previous mapping for it.
|
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.replaceAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.replacexAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if only if there is a previous mapping for it.
|
IgniteInternalFuture<GridCacheReturn> |
GridNearAtomicCache.replacexAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<IgniteInternalTx> |
GridNearTxLocal.rollbackAsync()
Asynchronously rollback this transaction.
|
IgniteInternalFuture<IgniteInternalTx> |
GridNearTxLocal.rollbackAsyncLocal()
Rolls back local part of colocated transaction.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridLocalLockFuture<K,V>
Cache lock future.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridLocalCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
CacheEntryPredicate[] filter)
All or nothing synchronous lock for passed in keys.
|
IgniteInternalFuture<Boolean> |
GridLocalCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<?> |
GridLocalCache.removeAllAsync() |
IgniteInternalFuture<Boolean> |
GridLocalCache.txLockAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean invalidate,
long accessTtl,
CacheEntryPredicate[] filter) |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteInternalFuture |
GridLocalAtomicCache.asyncOp(Callable<?> op) |
IgniteInternalFuture<Map<K,V>> |
GridLocalAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridLocalAtomicCache.invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
GridLocalAtomicCache.invokeAllAsync(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>> |
GridLocalAtomicCache.invokeAsync(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
CacheEntryPredicate... filter)
All or nothing synchronous lock for passed in keys.
|
IgniteInternalFuture<?> |
GridLocalAtomicCache.putAllAsync(Map<? extends K,? extends V> m,
CacheEntryPredicate[] filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<V> |
GridLocalAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridLocalAtomicCache.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<?> |
GridLocalAtomicCache.removeAllAsync() |
IgniteInternalFuture<?> |
GridLocalAtomicCache.removeAllAsync(Collection<? extends K> keys,
CacheEntryPredicate[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<V> |
GridLocalAtomicCache.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.removeAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<GridCacheReturn> |
GridLocalAtomicCache.removexAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<V> |
GridLocalAtomicCache.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if there is a previous mapping for it.
|
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.replaceAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.replacexAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if only if there is a previous mapping for it.
|
IgniteInternalFuture<GridCacheReturn> |
GridLocalAtomicCache.replacexAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.txLockAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean invalidate,
long accessTtl,
CacheEntryPredicate[] filter) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
CacheQueryFuture<T>
Cache query future returned by query execution.
|
| 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 |
GridCacheQueryErrorFuture<T>
Error future.
|
class |
GridCacheQueryFutureAdapter<K,V,R>
Query future adapter.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<GridCacheSqlResult> |
GridCacheQueriesEx.execute(String space,
GridCacheTwoStepQuery qry) |
IgniteInternalFuture<GridCacheSqlResult> |
GridCacheQueriesProxy.execute(String space,
GridCacheTwoStepQuery qry) |
IgniteInternalFuture<GridCacheSqlResult> |
GridCacheQueriesImpl.execute(String space,
GridCacheTwoStepQuery qry) |
IgniteInternalFuture<GridCacheSqlResult> |
GridCacheQueriesEx.executeTwoStepQuery(String space,
String sqlQry,
Object... params) |
IgniteInternalFuture<GridCacheSqlResult> |
GridCacheQueriesProxy.executeTwoStepQuery(String space,
String sqlQry,
Object[] params) |
IgniteInternalFuture<GridCacheSqlResult> |
GridCacheQueriesImpl.executeTwoStepQuery(String space,
String sqlQry,
Object[] params) |
IgniteInternalFuture<List<GridQueryFieldMetadata>> |
GridCacheLocalFieldsQueryFuture.metadata() |
IgniteInternalFuture<List<GridQueryFieldMetadata>> |
GridCacheQueryMetadataAware.metadata() |
IgniteInternalFuture<List<GridQueryFieldMetadata>> |
GridCacheDistributedFieldsQueryFuture.metadata() |
IgniteInternalFuture<?> |
GridCacheQueriesProxy.rebuildAllIndexes()
Forces this cache to rebuild search indexes of all types.
|
IgniteInternalFuture<?> |
GridCacheQueryManager.rebuildAllIndexes()
Rebuilds all search indexes of all types.
|
IgniteInternalFuture<?> |
GridCacheQueriesImpl.rebuildAllIndexes()
Forces this cache to rebuild search indexes of all types.
|
IgniteInternalFuture<?> |
CacheQueries.rebuildAllIndexes()
Forces this cache to rebuild search indexes of all types.
|
IgniteInternalFuture<?> |
GridCacheQueriesProxy.rebuildIndexes(Class<?> cls)
Forces this cache to rebuild all search indexes of given value type.
|
IgniteInternalFuture<?> |
GridCacheQueryManager.rebuildIndexes(Class<?> valType)
Rebuilds all search indexes of given value type.
|
IgniteInternalFuture<?> |
GridCacheQueriesImpl.rebuildIndexes(Class<?> cls)
Forces this cache to rebuild all search indexes of given value type.
|
IgniteInternalFuture<?> |
CacheQueries.rebuildIndexes(Class<?> cls)
Forces this cache to rebuild all search indexes of given value type.
|
IgniteInternalFuture<?> |
GridCacheQueriesProxy.rebuildIndexes(String typeName)
Forces this cache to rebuild all search indexes of given value type.
|
IgniteInternalFuture<?> |
GridCacheQueryManager.rebuildIndexes(String typeName)
Rebuilds all search indexes of given value type.
|
IgniteInternalFuture<?> |
GridCacheQueriesImpl.rebuildIndexes(String typeName)
Forces this cache to rebuild all search indexes of given value type.
|
IgniteInternalFuture<?> |
CacheQueries.rebuildIndexes(String typeName)
Forces this cache to rebuild all search indexes of given value type.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<T> |
IgniteTxLocalAdapter.PostLockClosure1.apply(Boolean locked,
Exception e)
Closure body.
|
IgniteInternalFuture<T> |
IgniteTxLocalAdapter.PostLockClosure2.apply(Boolean locked,
Exception e)
Closure body.
|
IgniteInternalFuture<T> |
IgniteTxLocalAdapter.PostMissClosure.apply(T t,
Exception e)
Closure body.
|
IgniteInternalFuture<?> |
IgniteTxManager.awaitFinishAckAsync(UUID rmtNodeId,
long threadId)
Asynchronously waits for last finish request ack.
|
IgniteInternalFuture<IgniteInternalTx> |
IgniteInternalTx.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
protected <K,V> IgniteInternalFuture<Set<KeyCacheObject>> |
IgniteTxLocalAdapter.enlistWrite(GridCacheContext cacheCtx,
Collection<?> keys,
GridCacheEntryEx cached,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean implicit,
Map<?,?> lookup,
Map<?,javax.cache.processor.EntryProcessor<K,V,Object>> invokeMap,
Object[] invokeArgs,
boolean retval,
boolean lockOnly,
CacheEntryPredicate[] filter,
GridCacheReturn ret,
Collection<KeyCacheObject> enlisted,
Map<KeyCacheObject,GridCacheDrInfo> drPutMap,
Map<KeyCacheObject,GridCacheVersion> drRmvMap)
Internal routine for putAll(..)
|
IgniteInternalFuture<IgniteInternalTx> |
IgniteTxHandler.finish(UUID nodeId,
GridNearTxLocal locTx,
GridNearTxFinishRequest req) |
IgniteInternalFuture<IgniteInternalTx> |
IgniteTxHandler.finishColocatedLocal(boolean commit,
GridNearTxLocal tx) |
IgniteInternalFuture<IgniteInternalTx> |
IgniteTxAdapter.finishFuture() |
IgniteInternalFuture<IgniteInternalTx> |
IgniteInternalTx.finishFuture() |
IgniteInternalFuture<Boolean> |
IgniteTxManager.finishTxs(long topVer)
Creates a future that will wait for all ongoing transactions that maybe affected by topology update
to be finished.
|
<K,V> IgniteInternalFuture<Map<K,V>> |
IgniteTxLocalEx.getAllAsync(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys,
GridCacheEntryEx cached,
boolean deserializePortable,
boolean skipVals,
boolean keepCacheObjects) |
<K,V> IgniteInternalFuture<Map<K,V>> |
IgniteTxLocalAdapter.getAllAsync(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys,
GridCacheEntryEx cached,
boolean deserializePortable,
boolean skipVals,
boolean keepCacheObjects) |
<K> IgniteInternalFuture<?> |
IgniteTxLocalEx.groupLockAsync(GridCacheContext cacheCtx,
Collection<K> keys)
Performs keys locking for affinity-based group lock transactions.
|
<K> IgniteInternalFuture<?> |
IgniteTxLocalAdapter.groupLockAsync(GridCacheContext cacheCtx,
Collection<K> keys)
Performs keys locking for affinity-based group lock transactions.
|
<K,V,T> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.invokeAsync(GridCacheContext cacheCtx,
Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,Object>> map,
Object... invokeArgs) |
<K,V,T> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.invokeAsync(GridCacheContext cacheCtx,
Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,Object>> map,
Object... invokeArgs) |
IgniteInternalFuture<Boolean> |
IgniteTxLocalEx.loadMissing(GridCacheContext cacheCtx,
boolean readThrough,
boolean async,
Collection<KeyCacheObject> keys,
boolean deserializePortable,
boolean skipVals,
IgniteBiInClosure<KeyCacheObject,Object> c) |
IgniteInternalFuture<Boolean> |
IgniteTxLocalAdapter.loadMissing(GridCacheContext cacheCtx,
boolean readThrough,
boolean async,
Collection<KeyCacheObject> keys,
boolean deserializePortable,
boolean skipVals,
IgniteBiInClosure<KeyCacheObject,Object> c) |
protected abstract IgniteInternalFuture<T> |
IgniteTxLocalAdapter.PostLockClosure2.postLock()
Post lock callback.
|
protected abstract IgniteInternalFuture<T> |
IgniteTxLocalAdapter.PostMissClosure.postMiss(T t)
Post lock callback.
|
IgniteInternalFuture<IgniteInternalTx> |
IgniteInternalTx.prepareAsync()
Prepare stage.
|
IgniteInternalFuture<IgniteInternalTx> |
IgniteTxHandler.prepareTx(UUID nearNodeId,
GridNearTxLocal locTx,
GridNearTxPrepareRequest req,
IgniteInClosure<GridNearTxPrepareResponse> completeCb) |
IgniteInternalFuture<IgniteInternalTx> |
IgniteTxHandler.processNearTxFinishRequest(UUID nodeId,
GridNearTxFinishRequest req) |
IgniteInternalFuture<IgniteInternalTx> |
IgniteTxHandler.processNearTxPrepareRequest(UUID nearNodeId,
GridNearTxPrepareRequest req) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.putAllAsync(GridCacheContext cacheCtx,
Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate[] filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.putAllAsync(GridCacheContext cacheCtx,
Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<?> |
IgniteTxLocalEx.putAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheDrInfo> drMap) |
IgniteInternalFuture<?> |
IgniteTxLocalAdapter.putAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheDrInfo> drMap) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.removeAllAsync(GridCacheContext cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx cached,
boolean retval,
CacheEntryPredicate[] filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.removeAllAsync(GridCacheContext cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx cached,
boolean retval,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<?> |
IgniteTxLocalEx.removeAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheVersion> drMap) |
IgniteInternalFuture<?> |
IgniteTxLocalAdapter.removeAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheVersion> drMap) |
IgniteInternalFuture<IgniteInternalTx> |
IgniteInternalTx.rollbackAsync()
Asynchronously rollback this transaction.
|
| Modifier and Type | Method and Description |
|---|---|
<T,R> IgniteInternalFuture<Collection<R>> |
GridClosureProcessor.broadcast(IgniteClosure<T,R> job,
T arg,
Collection<ClusterNode> nodes) |
<T,R> IgniteInternalFuture<Collection<R>> |
GridClosureProcessor.broadcastNoFailover(IgniteClosure<T,R> job,
T arg,
Collection<ClusterNode> nodes) |
<R> IgniteInternalFuture<R> |
GridClosureProcessor.callAsyncNoFailover(GridClosureCallMode mode,
Callable<R> job,
Collection<ClusterNode> nodes,
boolean sys) |
<R> IgniteInternalFuture<Collection<R>> |
GridClosureProcessor.callAsyncNoFailover(GridClosureCallMode mode,
Collection<? extends Callable<R>> jobs,
Collection<ClusterNode> nodes,
boolean sys) |
<R> IgniteInternalFuture<R> |
GridClosureProcessor.callLocalSafe(Callable<R> c)
Executes closure on system pool.
|
<R> IgniteInternalFuture<R> |
GridClosureProcessor.callLocalSafe(Callable<R> c,
boolean sys)
Executes closure on system pool.
|
<R> IgniteInternalFuture<R> |
GridClosureProcessor.callLocalSafe(Callable<R> c,
GridClosurePolicy plc)
Companion to
GridClosureProcessor.callLocal(Callable, boolean) but in case of rejected execution re-runs
the closure in the current thread (blocking). |
IgniteInternalFuture<?> |
GridClosureProcessor.runLocalSafe(Runnable c)
Executes closure on system pool.
|
IgniteInternalFuture<?> |
GridClosureProcessor.runLocalSafe(Runnable c,
boolean sys)
Companion to
GridClosureProcessor.runLocal(Runnable, boolean) but in case of rejected execution re-runs
the closure in the current thread (blocking). |
IgniteInternalFuture<?> |
GridClosureProcessor.runLocalSafe(Runnable c,
GridClosurePolicy plc)
Companion to
GridClosureProcessor.runLocal(Runnable, boolean) but in case of rejected execution re-runs
the closure in the current thread (blocking). |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<UUID> |
GridContinuousProcessor.startRoutine(GridContinuousHandler hnd,
int bufSize,
long interval,
boolean autoUnsubscribe,
IgnitePredicate<ClusterNode> prjPred) |
IgniteInternalFuture<?> |
GridContinuousProcessor.stopRoutine(UUID routineId) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<?> |
DataStreamerImpl.internalFuture() |
| Modifier and Type | Method and Description |
|---|---|
abstract IgniteInternalFuture<?> |
HadoopProcessorAdapter.finishFuture(HadoopJobId jobId)
Gets Hadoop job finish future.
|
IgniteInternalFuture<?> |
Hadoop.finishFuture(HadoopJobId jobId)
Gets Hadoop finish future for particular job.
|
IgniteInternalFuture<?> |
HadoopNoopProcessor.finishFuture(HadoopJobId jobId)
Gets Hadoop job finish future.
|
abstract IgniteInternalFuture<?> |
HadoopProcessorAdapter.submit(HadoopJobId jobId,
HadoopJobInfo jobInfo)
Submits job to job tracker.
|
IgniteInternalFuture<?> |
Hadoop.submit(HadoopJobId jobId,
HadoopJobInfo jobInfo)
Submits job to job tracker.
|
IgniteInternalFuture<?> |
HadoopNoopProcessor.submit(HadoopJobId jobId,
HadoopJobInfo jobInfo)
Submits job to job tracker.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<?> |
IgfsEx.awaitDeletesAsync()
Asynchronously await for all entries existing in trash to be removed.
|
IgniteInternalFuture<?> |
IgfsImpl.awaitDeletesAsync()
Asynchronously await for all entries existing in trash to be removed.
|
IgniteInternalFuture<?> |
IgfsAsyncImpl.awaitDeletesAsync()
Asynchronously await for all entries existing in trash to be removed.
|
IgniteInternalFuture<byte[]> |
IgfsDataManager.dataBlock(IgfsFileInfo fileInfo,
IgfsPath path,
long blockIdx,
IgfsSecondaryFileSystemPositionedReadable secReader)
Get data block for specified file ID and block index.
|
protected IgniteInternalFuture<byte[]> |
IgfsInputStreamImpl.dataBlock(IgfsFileInfo fileInfo,
long blockIdx)
Get data block for specified block index.
|
IgniteInternalFuture<Object> |
IgfsDataManager.delete(IgfsFileInfo fileInfo)
Delete file's data from data cache.
|
IgniteInternalFuture<IgfsMessage> |
IgfsServerHandler.handleAsync(IgfsClientSession ses,
IgfsMessage msg,
DataInput in)
Asynchronously handles incoming message.
|
IgniteInternalFuture<Boolean> |
IgfsDataManager.writeStart(IgfsFileInfo fileInfo)
Registers write future in igfs data manager.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<GridCacheSqlResult> |
GridQueryIndexing.queryTwoStep(String space,
GridCacheTwoStepQuery qry)
Runs two step query.
|
IgniteInternalFuture<GridCacheSqlResult> |
GridQueryProcessor.queryTwoStep(String space,
GridCacheTwoStepQuery qry) |
IgniteInternalFuture<GridCacheSqlResult> |
GridQueryIndexing.queryTwoStep(String space,
String sqlQry,
Object[] params) |
IgniteInternalFuture<GridCacheSqlResult> |
GridQueryProcessor.queryTwoStep(String space,
String sqlQry,
Object[] params) |
IgniteInternalFuture<?> |
GridQueryProcessor.rebuildAllIndexes()
Rebuilds all search indexes for given spi.
|
IgniteInternalFuture<?> |
GridQueryProcessor.rebuildIndexes(String space,
String valTypeName)
Rebuilds all search indexes of given value type for given space of spi.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<GridRestResponse> |
GridRestProtocolHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<GridRestResponse> |
GridRestCommandHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<GridRestResponse> |
GridCacheQueryCommandHandler.handleAsync(GridRestRequest req) |
IgniteInternalFuture<GridRestResponse> |
GridCacheCommandHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<GridRestResponse> |
DataStructuresCommandHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<GridRestResponse> |
GridTaskCommandHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<GridRestResponse> |
GridTopologyCommandHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<GridRestResponse> |
GridVersionCommandHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridServiceDeploymentFuture
Service deployment future.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<?> |
GridServiceProcessor.cancel(String name) |
IgniteInternalFuture<?> |
GridServiceProcessor.cancelAll() |
IgniteInternalFuture<?> |
GridServiceProcessor.deploy(ServiceConfiguration cfg) |
IgniteInternalFuture<?> |
GridServiceProcessor.deployClusterSingleton(ClusterGroup prj,
String name,
Service svc) |
IgniteInternalFuture<?> |
GridServiceProcessor.deployKeyAffinitySingleton(String name,
Service svc,
String cacheName,
Object affKey) |
IgniteInternalFuture<?> |
GridServiceProcessor.deployMultiple(ClusterGroup prj,
String name,
Service svc,
int totalCnt,
int maxPerNodeCnt) |
IgniteInternalFuture<?> |
GridServiceProcessor.deployNodeSingleton(ClusterGroup prj,
String name,
Service svc) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridStreamerStageExecutionFuture
Streamer execution future.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
IgniteUtils.asyncLogError(IgniteInternalFuture<?> f,
IgniteLogger log)
Adds listener to asynchronously log errors.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridCompoundFuture<T,R>
Future composed of multiple inner futures.
|
class |
GridCompoundIdentityFuture<T>
Future composed of multiple inner futures.
|
class |
GridEmbeddedFuture<A,B>
Future which waits for embedded future to complete and then asynchronously executes
provided closure with embedded future result.
|
class |
GridFinishedFuture<T>
Future that is completed at creation time.
|
class |
GridFutureAdapter<R>
Future adapter.
|
| Modifier and Type | Field and Description |
|---|---|
protected IgniteInternalFuture<V> |
IgniteFutureImpl.fut |
| Modifier and Type | Method and Description |
|---|---|
<T> IgniteInternalFuture<T> |
GridFutureAdapter.chain(IgniteClosure<? super IgniteInternalFuture<R>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
<R> IgniteInternalFuture<R> |
GridFinishedFuture.chain(IgniteClosure<? super IgniteInternalFuture<T>,R> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
IgniteInternalFuture<V> |
IgniteFutureImpl.internalFuture() |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteInternalFuture<T>> |
GridCompoundFuture.futures()
Gets collection of futures.
|
Collection<IgniteInternalFuture<T>> |
GridCompoundFuture.pending()
Gets pending (unfinished) futures.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCompoundFuture.add(IgniteInternalFuture<T> fut)
Adds a future to this compound future.
|
void |
GridCompoundFuture.addAll(IgniteInternalFuture<T>... futs)
Adds futures to this compound future.
|
void |
GridFutureChainListener.apply(IgniteInternalFuture<T> t)
Closure body.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCompoundFuture.addAll(Iterable<IgniteInternalFuture<T>> futs)
Adds futures to this compound future.
|
<T> IgniteInternalFuture<T> |
GridFutureAdapter.chain(IgniteClosure<? super IgniteInternalFuture<R>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
<R> IgniteInternalFuture<R> |
GridFinishedFuture.chain(IgniteClosure<? super IgniteInternalFuture<T>,R> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
void |
GridFutureAdapter.listen(IgniteInClosure<? super IgniteInternalFuture<R>> lsnr0)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridFinishedFuture.listen(IgniteInClosure<? super IgniteInternalFuture<T>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Constructor and Description |
|---|
GridEmbeddedFuture(IgniteBiClosure<B,Exception,A> c,
IgniteInternalFuture<B> embedded) |
GridEmbeddedFuture(IgniteInternalFuture<B> embedded,
IgniteBiClosure<B,Exception,IgniteInternalFuture<A>> c)
Embeds futures.
|
GridEmbeddedFuture(IgniteInternalFuture<B> embedded,
IgniteBiClosure<B,Exception,IgniteInternalFuture<A>> c1,
IgniteBiClosure<A,Exception,A> c2)
Embeds futures.
|
IgniteFutureImpl(IgniteInternalFuture<V> fut) |
| Constructor and Description |
|---|
GridCompoundFuture(IgniteReducer<T,R> rdc,
Iterable<IgniteInternalFuture<T>> futs) |
GridEmbeddedFuture(IgniteInternalFuture<B> embedded,
IgniteBiClosure<B,Exception,IgniteInternalFuture<A>> c)
Embeds futures.
|
GridEmbeddedFuture(IgniteInternalFuture<B> embedded,
IgniteBiClosure<B,Exception,IgniteInternalFuture<A>> c1,
IgniteBiClosure<A,Exception,A> c2)
Embeds futures.
|
GridFutureChainListener(GridFutureAdapter<R> fut,
IgniteClosure<? super IgniteInternalFuture<T>,R> doneCb)
Constructs chain listener.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> IgniteInternalFuture<T> |
GridFunc.awaitOne(IgniteInternalFuture<T>... futs)
Waits for one completed future from passed and returns it.
|
static <T> IgniteInternalFuture<T> |
GridFunc.awaitOne(Iterable<IgniteInternalFuture<T>> futs)
Waits for the first completed future from passed and returns it.
|
| Modifier and Type | Method and Description |
|---|---|
static IgnitePredicate<IgniteInternalFuture<?>> |
GridFunc.unfinishedFutures()
Returns predicate for filtering unfinished futures.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> void |
GridFunc.awaitAll(IgniteInternalFuture<T>... futs)
Waits until all passed futures will be executed.
|
static <T> IgniteInternalFuture<T> |
GridFunc.awaitOne(IgniteInternalFuture<T>... futs)
Waits for one completed future from passed and returns it.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> void |
GridFunc.awaitAll(Collection<IgniteInternalFuture<T>> futs)
Waits until all passed futures will be executed.
|
static <T> void |
GridFunc.awaitAll(long timeout,
Collection<IgniteInternalFuture<T>> futs)
Waits until all passed futures will be executed.
|
static <T,R> R |
GridFunc.awaitAll(long timeout,
IgniteReducer<T,R> rdc,
Collection<IgniteInternalFuture<T>> futs)
Awaits for all futures to complete and optionally reduces all results into one.
|
static <T> IgniteInternalFuture<T> |
GridFunc.awaitOne(Iterable<IgniteInternalFuture<T>> futs)
Waits for the first completed future from passed and returns it.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
GridNioFuture<R>
NIO future.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNioEmbeddedFuture<R>
Future that delegates to some other future.
|
class |
GridNioFinishedFuture<R>
Future that represents already completed result.
|
class |
GridNioFutureImpl<R>
Default future implementation.
|
| Modifier and Type | Method and Description |
|---|---|
GridNioFuture<?> |
GridNioServer.sendSystem(GridNioSession ses,
Message msg,
IgniteInClosure<? super IgniteInternalFuture<?>> lsnr)
Adds message at the front of the queue without acquiring back pressure semaphore.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridWorkerFuture<T>
Future for locally executed closure that defines cancellation logic.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015