| Modifier and Type | Method and Description |
|---|---|
<T> GridFuture<T> |
GridFuture.chain(GridClosure<? super GridFuture<R>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
GridFuture<Collection<GridTuple3<String,Boolean,String>>> |
Grid.startNodes(Collection<Map<String,Object>> hosts,
Map<String,Object> dflts,
boolean restart,
int timeout,
int maxConn)
Starts one or more nodes on remote host(s).
|
GridFuture<Collection<GridTuple3<String,Boolean,String>>> |
Grid.startNodes(File file,
boolean restart,
int timeout,
int maxConn)
Starts one or more nodes on remote host(s).
|
| Modifier and Type | Method and Description |
|---|---|
<T> GridFuture<T> |
GridFuture.chain(GridClosure<? super GridFuture<R>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
void |
GridFuture.listenAsync(GridInClosure<? super GridFuture<R>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<GridCacheTx> |
GridCacheTx.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
GridFuture<?> |
GridCache.forceRepartition()
Forces this cache node to re-balance its partitions.
|
GridFuture<Map<K,V>> |
GridCacheProjection.getAllAsync(Collection<? extends K> keys)
Asynchronously retrieves values mapped to the specified keys from cache.
|
GridFuture<V> |
GridCacheEntry.getAsync()
This method has the same semantic as
GridCacheProjection.getAsync(Object) method. |
GridFuture<V> |
GridCacheProjection.getAsync(K key)
Asynchronously retrieves value mapped to the specified key from cache.
|
GridFuture<?> |
GridCache.loadCacheAsync(GridBiPredicate<K,V> p,
long ttl,
Object... args)
Asynchronously delegates to
GridCacheStore.loadCache(GridBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
GridFuture<Boolean> |
GridCacheProjection.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
GridFuture<Boolean> |
GridCacheProjection.lockAsync(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
GridFuture<Boolean> |
GridCacheEntry.lockAsync(long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
GridFuture<?> |
GridCacheProjection.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<V> |
GridCacheProjection.putAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously stores given key-value pair in cache.
|
GridFuture<V> |
GridCacheProjection.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<Boolean> |
GridCacheProjection.putxAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
Stores given key-value pair in cache.
|
GridFuture<Boolean> |
GridCacheProjection.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<?> |
GridCacheProjection.reloadAllAsync()
Asynchronously reloads all specified entries from underlying
persistent storage.
|
GridFuture<?> |
GridCacheProjection.reloadAllAsync(Collection<? extends K> keys)
Asynchronously reloads all specified entries from underlying
persistent storage.
|
GridFuture<V> |
GridCacheEntry.reloadAsync()
This method has the same semantic as
GridCacheProjection.reloadAsync(Object) method. |
GridFuture<V> |
GridCacheProjection.reloadAsync(K key)
Asynchronously reloads a single key from persistent storage.
|
GridFuture<?> |
GridCacheProjection.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridCacheProjection.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<V> |
GridCacheEntry.removeAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.removeAsync(Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheProjection.removeAsync(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes given key mapping from cache.
|
GridFuture<Boolean> |
GridCacheProjection.removeAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
GridFuture<Boolean> |
GridCacheEntry.removeAsync(V val)
This method has the same semantic as
GridCacheProjection.removeAsync(Object, Object) method. |
GridFuture<Boolean> |
GridCacheEntry.removexAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.removexAsync(Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheProjection.removexAsync(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes given key mapping from cache.
|
GridFuture<V> |
GridCacheProjection.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if if there is a previous mapping for it.
|
GridFuture<Boolean> |
GridCacheProjection.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. |
GridFuture<V> |
GridCacheEntry.replaceAsync(V val)
This method has the same semantic as
GridCacheProjection.replaceAsync(Object, Object) method. |
GridFuture<Boolean> |
GridCacheEntry.replaceAsync(V oldVal,
V newVal)
This method has the same semantic as
GridCacheProjection.replaceAsync(Object, Object, Object) method. |
GridFuture<Boolean> |
GridCacheProjection.replacexAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if only if there is a previous mapping for it.
|
GridFuture<Boolean> |
GridCacheEntry.replacexAsync(V val)
This method has the same semantic as
GridCacheProjection.replacexAsync(Object, Object) method. |
GridFuture<V> |
GridCacheEntry.setAsync(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.putAsync(Object, Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheEntry.setIfAbsentAsync(V val)
This method has the same semantic as
GridCacheProjection.putIfAbsentAsync(Object, Object) method. |
GridFuture<Boolean> |
GridCacheEntry.setxAsync(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.putxAsync(Object, Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheEntry.setxIfAbsentAsync(V val)
This method has the same semantic as
GridCacheProjection.putxIfAbsentAsync(Object, Object) method. |
GridFuture<?> |
GridCacheProjection.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
GridFuture<?> |
GridCacheProjection.transformAllAsync(Set<? extends K> keys,
GridClosure<V,V> transformer)
Stores result of applying the specified transform closure to previous values associated
with the specified keys in cache.
|
GridFuture<?> |
GridCacheEntry.transformAsync(GridClosure<V,V> transformer)
This method has the same semantic as
GridCacheProjection.transformAsync(Object, GridClosure) method. |
GridFuture<?> |
GridCacheProjection.transformAsync(K key,
GridClosure<V,V> transformer)
Stores result of applying
transformer closure to the previous value associated with
given key in cache. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
GridCacheQueryFuture<T>
Cache query future returned by query execution.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<?> |
GridCacheQueries.rebuildAllIndexes()
Forces this cache to rebuild search indexes of all types.
|
GridFuture<?> |
GridCacheQueries.rebuildIndexes(Class<?> cls)
Forces this cache to rebuild all search indexes of given value type.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
GridComputeTaskFuture<R>
This class defines a handler for asynchronous task execution.
|
| Modifier and Type | Method and Description |
|---|---|
<R> GridFuture<R> |
GridCompute.affinityCall(String cacheName,
Object affKey,
Callable<R> job)
Executes given job on the node where data for provided affinity key is located
(a.k.a.
|
GridFuture<?> |
GridCompute.affinityRun(String cacheName,
Object affKey,
Runnable job)
Executes given job on the node where data for provided affinity key is located
(a.k.a.
|
<T,R> GridFuture<Collection<R>> |
GridCompute.apply(GridClosure<T,R> job,
Collection<? extends T> args)
Executes provided closure job on nodes within this grid projection.
|
<R,T> GridFuture<R> |
GridCompute.apply(GridClosure<T,R> job,
T arg)
Executes provided closure job on a node in this grid projection.
|
<R1,R2,T> GridFuture<R2> |
GridCompute.apply(GridClosure<T,R1> job,
Collection<? extends T> args,
GridReducer<R1,R2> rdc)
Executes provided closure job on nodes within this grid projection.
|
<R> GridFuture<Collection<R>> |
GridCompute.broadcast(Callable<R> job)
Broadcasts given job to all nodes in grid projection.
|
<R,T> GridFuture<Collection<R>> |
GridCompute.broadcast(GridClosure<T,R> job,
T arg)
Broadcasts given closure job with passed in argument to all nodes in grid projection.
|
GridFuture<?> |
GridCompute.broadcast(Runnable job)
Broadcasts given job to all nodes in grid projection.
|
<R> GridFuture<R> |
GridCompute.call(Callable<R> job)
Executes provided job on a node in this grid projection.
|
<R> GridFuture<Collection<R>> |
GridCompute.call(Collection<? extends Callable<R>> jobs)
Executes collection of jobs on nodes within this grid projection.
|
<R1,R2> GridFuture<R2> |
GridCompute.call(Collection<? extends Callable<R1>> jobs,
GridReducer<R1,R2> rdc)
Executes collection of jobs on nodes within this grid projection.
|
GridFuture<?> |
GridCompute.run(Collection<? extends Runnable> jobs)
Executes collection of jobs on grid nodes within this grid projection.
|
GridFuture<?> |
GridCompute.run(Runnable job)
Executes provided job on a node in this grid projection.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<?> |
GridDataLoader.addData(Collection<? extends Map.Entry<K,V>> entries)
Adds data for loading on remote node.
|
GridFuture<?> |
GridDataLoader.addData(K key,
V val)
Adds data for loading on remote node.
|
GridFuture<?> |
GridDataLoader.addData(Map.Entry<K,V> entry)
Adds data for loading on remote node.
|
GridFuture<?> |
GridDataLoader.addData(Map<K,V> entries)
Adds data for loading on remote node.
|
GridFuture<?> |
GridDataLoader.future()
Gets future for this loading process.
|
GridFuture<?> |
GridDataLoader.removeData(K key)
Adds key for removal on remote node.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<?> |
GridDr.senderCacheDrStateTransfer(String cacheName,
byte... dataCenterId)
Starts full state transfer for the given sender cache.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends GridEvent> |
GridEvents.remoteListen(GridBiPredicate<UUID,T> locLsnr,
GridPredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the projection (possibly including
local node if it belongs to the projection as well).
|
<T extends GridEvent> |
GridEvents.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
GridBiPredicate<UUID,T> locLsnr,
GridPredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the projection (possibly including
local node if it belongs to the projection as well).
|
<T extends GridEvent> |
GridEvents.remoteQuery(GridPredicate<T> p,
long timeout,
int... types)
Asynchronously queries nodes in this projection for events using passed in predicate filter for event
selection.
|
GridFuture<?> |
GridEvents.stopRemoteListen(UUID opId)
Stops listening to remote events.
|
<T extends GridEvent> |
GridEvents.waitForLocal(GridPredicate<T> filter,
int... types)
Gets event future that allows for asynchronous waiting for the specified events.
|
| Modifier and Type | Method and Description |
|---|---|
<T,R> GridFuture<R> |
GridGgfs.execute(Class<? extends GridGgfsTask<T,R>> taskCls,
GridGgfsRecordResolver rslvr,
Collection<GridGgfsPath> paths,
boolean skipNonExistentFiles,
long maxRangeLen,
T arg)
Executes GGFS task asynchronously with overridden maximum range length (see
GridGgfsConfiguration.getMaximumTaskRangeLength() for more information). |
<T,R> GridFuture<R> |
GridGgfs.execute(Class<? extends GridGgfsTask<T,R>> taskCls,
GridGgfsRecordResolver rslvr,
Collection<GridGgfsPath> paths,
T arg)
Executes GGFS task asynchronously.
|
<T,R> GridFuture<R> |
GridGgfs.execute(GridGgfsTask<T,R> task,
GridGgfsRecordResolver rslvr,
Collection<GridGgfsPath> paths,
boolean skipNonExistentFiles,
long maxRangeLen,
T arg)
Executes GGFS task asynchronously with overridden maximum range length (see
GridGgfsConfiguration.getMaximumTaskRangeLength() for more information). |
<T,R> GridFuture<R> |
GridGgfs.execute(GridGgfsTask<T,R> task,
GridGgfsRecordResolver rslvr,
Collection<GridGgfsPath> paths,
T arg)
Executes GGFS task asynchronously.
|
GridFuture<?> |
GridGgfs.format()
Formats the file system removing all existing entries from it.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridTaskFutureImpl<R>
This class provide implementation for task future.
|
| Modifier and Type | Method and Description |
|---|---|
<R> GridFuture<R> |
GridComputeImpl.affinityCall(String cacheName,
Object affKey,
Callable<R> job)
Executes given job on the node where data for provided affinity key is located
(a.k.a.
|
GridFuture<?> |
GridComputeImpl.affinityRun(String cacheName,
Object affKey,
Runnable job)
Executes given job on the node where data for provided affinity key is located
(a.k.a.
|
<T,R> GridFuture<Collection<R>> |
GridComputeImpl.apply(GridClosure<T,R> job,
Collection<? extends T> args)
Executes provided closure job on nodes within this grid projection.
|
<R,T> GridFuture<R> |
GridComputeImpl.apply(GridClosure<T,R> job,
T arg)
Executes provided closure job on a node in this grid projection.
|
<R1,R2,T> GridFuture<R2> |
GridComputeImpl.apply(GridClosure<T,R1> job,
Collection<? extends T> args,
GridReducer<R1,R2> rdc)
Executes provided closure job on nodes within this grid projection.
|
<R> GridFuture<Collection<R>> |
GridComputeImpl.broadcast(Callable<R> job)
Broadcasts given job to all nodes in grid projection.
|
<R,T> GridFuture<Collection<R>> |
GridComputeImpl.broadcast(GridClosure<T,R> job,
T arg)
Broadcasts given closure job with passed in argument to all nodes in grid projection.
|
GridFuture<?> |
GridComputeImpl.broadcast(Runnable job)
Broadcasts given job to all nodes in grid projection.
|
<R> GridFuture<R> |
GridComputeImpl.call(Callable<R> job)
Executes provided job on a node in this grid projection.
|
<R> GridFuture<Collection<R>> |
GridComputeImpl.call(Collection<? extends Callable<R>> jobs)
Executes collection of jobs on nodes within this grid projection.
|
<R1,R2> GridFuture<R2> |
GridComputeImpl.call(Collection<? extends Callable<R1>> jobs,
GridReducer<R1,R2> rdc)
Executes collection of jobs on nodes within this grid projection.
|
<R> GridFuture<R> |
GridSchedulerImpl.callLocal(Callable<R> c)
Executes given callable on internal system thread pool asynchronously.
|
<T extends GridEvent> |
GridEventsImpl.remoteListen(GridBiPredicate<UUID,T> locLsnr,
GridPredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the projection (possibly including
local node if it belongs to the projection as well).
|
<T extends GridEvent> |
GridEventsImpl.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
GridBiPredicate<UUID,T> locLsnr,
GridPredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the projection (possibly including
local node if it belongs to the projection as well).
|
GridFuture<UUID> |
GridMessagingImpl.remoteListen(Object topic,
GridBiPredicate<UUID,?> p)
Adds a message listener for a given topic to all nodes in the projection (possibly including
this node if it belongs to the projection as well).
|
<T extends GridEvent> |
GridEventsImpl.remoteQuery(GridPredicate<T> p,
long timeout,
int... types)
Asynchronously queries nodes in this projection for events using passed in predicate filter for event
selection.
|
GridFuture<?> |
GridComputeImpl.run(Collection<? extends Runnable> jobs)
Executes collection of jobs on grid nodes within this grid projection.
|
GridFuture<?> |
GridComputeImpl.run(Runnable job)
Executes provided job on a node in this grid projection.
|
GridFuture<?> |
GridSchedulerImpl.runLocal(Runnable r)
Executes given closure on internal system thread pool asynchronously.
|
GridFuture<Boolean> |
GridKernal.sendAdminEmailAsync(String subj,
String body,
boolean html)
Schedule sending of given email to all configured admin emails.
|
GridFuture<Boolean> |
GridEx.sendAdminEmailAsync(String subj,
String body,
boolean html)
Schedule sending of given email to all configured admin emails.
|
GridFuture<Collection<GridTuple3<String,Boolean,String>>> |
GridKernal.startNodes(Collection<Map<String,Object>> hosts,
Map<String,Object> dflts,
boolean restart,
int timeout,
int maxConn)
Starts one or more nodes on remote host(s).
|
GridFuture<Collection<GridTuple3<String,Boolean,String>>> |
GridKernal.startNodes(File file,
boolean restart,
int timeout,
int maxConn)
Starts one or more nodes on remote host(s).
|
GridFuture<?> |
GridEventsImpl.stopRemoteListen(UUID opId)
Stops listening to remote events.
|
GridFuture<?> |
GridMessagingImpl.stopRemoteListen(UUID opId)
Unregisters all listeners identified with provided operation ID on all nodes in this projection.
|
<T extends GridEvent> |
GridEventsImpl.waitForLocal(GridPredicate<T> filter,
int... types)
Gets event future that allows for asynchronous waiting for the specified events.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<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 GridEvent> |
GridEventStorageManager.remoteEventsAsync(GridPredicate<T> p,
Collection<? extends GridNode> nodes,
long timeout) |
<T extends GridEvent> |
GridEventStorageManager.waitForEvent(GridPredicate<T> p,
int... types) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<?> |
GridIndexingManager.rebuildAllIndexes(String spi)
Rebuilds all search indexes for given spi.
|
GridFuture<?> |
GridIndexingManager.rebuildIndexes(String spi,
String space,
Class<?> valType)
Rebuilds all search indexes of given value type for given space of spi.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<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<K,R>
Update future for atomic cache.
|
interface |
GridCacheFuture<R>
This interface should be implemented by all distributed futures.
|
interface |
GridCacheMvccFuture<K,V,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 | Field and Description |
|---|---|
protected GridBiClosure<Collection<K>,Boolean,GridFuture<Object>> |
GridCacheAdapter.beforePessimisticLock
Before lock callback.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<Long> |
GridCacheAffinityManager.affinityReadyFuture(long topVer)
Gets affinity ready future, a future that will be completed after affinity with given
topology version is calculated.
|
GridFuture<T> |
GridCacheTxLocalAdapter.PostLockClosure1.apply(Boolean locked,
Exception e)
Closure body.
|
GridFuture<T> |
GridCacheTxLocalAdapter.PostLockClosure2.apply(Boolean locked,
Exception e)
Closure body.
|
GridFuture<T> |
GridCacheTxLocalAdapter.PostMissClosure.apply(T t,
Exception e)
Closure body.
|
protected <T> GridFuture<T> |
GridCacheAdapter.asyncOp(GridCacheTxLocalAdapter<K,V> tx,
GridCacheAdapter.AsyncOp<T> op) |
protected <T> GridFuture<T> |
GridCacheAdapter.asyncOpAcquire()
Tries to acquire asynchronous operations permit, if limited.
|
GridFuture<?> |
GridCacheMvccManager.atomicFuture(GridCacheVersion futVer)
Gets future by given future ID.
|
GridFuture<?> |
GridCacheTxManager.awaitFinishAckAsync(UUID rmtNodeId,
long threadId)
Asynchronously waits for last finish request ack.
|
GridFuture<GridCacheTx> |
GridCacheTxProxyImpl.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
GridFuture<?> |
GridCacheProjectionEx.drStateTransfer(Collection<Byte> dataCenterIds)
Starts full state transfer.
|
GridFuture<?> |
GridCacheProjectionImpl.drStateTransfer(Collection<Byte> dataCenterIds)
Starts full state transfer.
|
GridFuture<?> |
GridCacheAdapter.drStateTransfer(Collection<Byte> dataCenterIds)
Starts full state transfer.
|
GridFuture<?> |
GridCacheProxyImpl.drStateTransfer(Collection<Byte> dataCenterIds)
Starts full state transfer.
|
protected GridFuture<Set<K>> |
GridCacheTxLocalAdapter.enlistWrite(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
long ttl,
boolean implicit,
Map<? extends K,? extends V> lookup,
Map<? extends K,? extends GridClosure<V,V>> transformMap,
boolean retval,
boolean lockOnly,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheReturn<V> ret,
Collection<K> enlisted,
Map<? extends K,GridCacheDrInfo<V>> drPutMap,
Map<? extends K,GridCacheVersion> drRmvMap)
Internal routine for putAll(..)
|
GridFuture<?> |
GridCacheMvccManager.finishAtomicUpdates(long topVer,
Collection<Integer> parts) |
GridFuture<?> |
GridCacheMvccManager.finishExplicitLocks(long topVer)
Creates a future that will wait for all explicit locks acquired on given topology
version to be released.
|
GridFuture<GridCacheTx> |
GridCacheTxAdapter.finishFuture() |
GridFuture<GridCacheTx> |
GridCacheTxEx.finishFuture() |
GridFuture<?> |
GridCacheMvccManager.finishKeys(Collection<K> keys,
long topVer) |
GridFuture<?> |
GridCacheMvccManager.finishLocks(Collection<Integer> parts,
long topVer) |
GridFuture<Boolean> |
GridCacheTxManager.finishTxs(Collection<Integer> parts,
long topVer)
Creates a future that will wait for all ongoing transactions that maybe affected by topology update
to be finished.
|
GridFuture<?> |
GridCacheAdapter.forceRepartition()
Forces this cache node to re-balance its partitions.
|
GridFuture<?> |
GridCacheProxyImpl.forceRepartition()
Forces this cache node to re-balance its partitions.
|
GridFuture |
GridCacheAdapter.FutureHolder.future()
Gets future.
|
GridFuture<GridCacheTxEx<K,V>> |
GridCacheTxLocalEx.future() |
GridFuture<Map<K,V>> |
GridCacheProjectionImpl.getAllAsync(Collection<? extends K> keys)
Asynchronously retrieves values mapped to the specified keys from cache.
|
GridFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys)
Asynchronously retrieves values mapped to the specified keys from cache.
|
GridFuture<Map<K,V>> |
GridCacheProxyImpl.getAllAsync(Collection<? extends K> keys)
Asynchronously retrieves values mapped to the specified keys from cache.
|
protected GridFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean checkTx,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<Map<K,V>> |
GridCacheTxLocalAdapter.getAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Map<K,V>> |
GridCacheTxLocalEx.getAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>> filter) |
GridFuture<Map<K,V>> |
GridCacheProjectionEx.getAllOutTxAsync(List<K> keys)
Asynchronously gets values from cache.
|
GridFuture<Map<K,V>> |
GridCacheProjectionImpl.getAllOutTxAsync(List<K> keys)
Asynchronously gets values from cache.
|
GridFuture<Map<K,V>> |
GridCacheAdapter.getAllOutTxAsync(List<K> keys)
Asynchronously gets values from cache.
|
GridFuture<Map<K,V>> |
GridCacheProxyImpl.getAllOutTxAsync(List<K> keys)
Asynchronously gets values from cache.
|
GridFuture<V> |
GridCacheEvictionEntry.getAsync()
This method has the same semantic as
GridCacheProjection.getAsync(Object) method. |
GridFuture<V> |
GridCacheEntryImpl.getAsync()
This method has the same semantic as
GridCacheProjection.getAsync(Object) method. |
GridFuture<V> |
GridCacheFilterEvaluationEntry.getAsync()
This method has the same semantic as
GridCacheProjection.getAsync(Object) method. |
GridFuture<V> |
GridCacheProjectionImpl.getAsync(K key)
Asynchronously retrieves value mapped to the specified key from cache.
|
GridFuture<V> |
GridCacheAdapter.getAsync(K key)
Asynchronously retrieves value mapped to the specified key from cache.
|
GridFuture<V> |
GridCacheProxyImpl.getAsync(K key)
Asynchronously retrieves value mapped to the specified key from cache.
|
GridFuture<V> |
GridCacheAdapter.getAsync(K key,
GridPredicate<GridCacheEntry<K,V>> filter) |
GridFuture<V> |
GridCacheProjectionEx.getForcePrimaryAsync(K key)
Asynchronously gets value from cache.
|
GridFuture<V> |
GridCacheProjectionImpl.getForcePrimaryAsync(K key)
Asynchronously gets value from cache.
|
GridFuture<V> |
GridCacheAdapter.getForcePrimaryAsync(K key)
Asynchronously gets value from cache.
|
GridFuture<V> |
GridCacheProxyImpl.getForcePrimaryAsync(K key)
Asynchronously gets value from cache.
|
GridFuture<?> |
GridCacheTxLocalAdapter.groupLockAsync(Collection<K> keys)
Performs keys locking for affinity-based group lock transactions.
|
GridFuture<?> |
GridCacheTxLocalEx.groupLockAsync(Collection<K> keys)
Performs keys locking for affinity-based group lock transactions.
|
GridFuture<?> |
GridCacheAdapter.loadCacheAsync(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Asynchronously delegates to
GridCacheStore.loadCache(GridBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
GridFuture<?> |
GridCacheProxyImpl.loadCacheAsync(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Asynchronously delegates to
GridCacheStore.loadCache(GridBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
GridFuture<Boolean> |
GridCacheTxLocalAdapter.loadMissing(boolean async,
Collection<? extends K> keys,
GridBiInClosure<K,V> c) |
GridFuture<Boolean> |
GridCacheTxLocalEx.loadMissing(boolean async,
Collection<? extends K> keys,
GridBiInClosure<K,V> c) |
GridFuture<Boolean> |
GridCacheProjectionImpl.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
GridFuture<Boolean> |
GridCacheProxyImpl.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
GridFuture<Boolean> |
GridCacheAdapter.lockAsync(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
GridFuture<Boolean> |
GridCacheProjectionImpl.lockAsync(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
GridFuture<Boolean> |
GridCacheProxyImpl.lockAsync(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
GridFuture<Boolean> |
GridCacheFilterEvaluationEntry.lockAsync(long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
GridFuture<Boolean> |
GridCacheEvictionEntry.lockAsync(long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
GridFuture<Boolean> |
GridCacheEntryImpl.lockAsync(long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
abstract GridFuture<T> |
GridCacheAdapter.AsyncOp.op(GridCacheTxLocalAdapter<K,V> tx) |
GridFuture<?> |
GridCacheProcessor.orderedPreloadFuture(int order)
Gets preload finish future for preload-ordered cache with given order.
|
GridFuture<?> |
GridCacheContext.partitionReleaseFuture(Collection<Integer> parts,
long topVer)
Waits for partition locks and transactions release.
|
protected abstract GridFuture<T> |
GridCacheTxLocalAdapter.PostLockClosure2.postLock()
Post lock callback.
|
protected abstract GridFuture<T> |
GridCacheTxLocalAdapter.PostMissClosure.postMiss(T t)
Post lock callback.
|
GridFuture<GridCacheTxEx<K,V>> |
GridCacheTxEx.prepareAsync()
Prepare stage.
|
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalAdapter.putAllAsync(Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalEx.putAllAsync(Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<?> |
GridCacheAdapter.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<?> |
GridCacheProjectionImpl.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<?> |
GridCacheProxyImpl.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<?> |
GridCacheProjectionEx.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data asynchronously.
|
GridFuture<?> |
GridCacheProjectionImpl.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data asynchronously.
|
GridFuture<?> |
GridCacheAdapter.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data asynchronously.
|
GridFuture<?> |
GridCacheProxyImpl.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data asynchronously.
|
GridFuture<?> |
GridCacheTxLocalAdapter.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap) |
GridFuture<?> |
GridCacheTxLocalEx.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap) |
GridFuture<V> |
GridCacheProjectionEx.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheAdapter.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheProxyImpl.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheProjectionImpl.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheTxLocalAdapter.putAsync(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<V> |
GridCacheTxLocalEx.putAsync(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<V> |
GridCacheProjectionImpl.putAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pair in cache.
|
GridFuture<V> |
GridCacheAdapter.putAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pair in cache.
|
GridFuture<V> |
GridCacheProxyImpl.putAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pair in cache.
|
GridFuture<V> |
GridCacheTxLocalAdapter.putAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<V> |
GridCacheTxLocalEx.putAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<V> |
GridCacheProjectionImpl.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<V> |
GridCacheAdapter.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<V> |
GridCacheProxyImpl.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<Boolean> |
GridCacheProjectionEx.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheAdapter.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheProxyImpl.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheProjectionImpl.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheTxLocalAdapter.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridCacheTxLocalEx.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridCacheAdapter.putxAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
Stores given key-value pair in cache.
|
GridFuture<Boolean> |
GridCacheProjectionImpl.putxAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
GridFuture<Boolean> |
GridCacheProxyImpl.putxAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
GridFuture<Boolean> |
GridCacheTxLocalAdapter.putxAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridCacheTxLocalEx.putxAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalAdapter.putxAsync0(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalEx.putxAsync0(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridCacheProjectionImpl.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<Boolean> |
GridCacheAdapter.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<Boolean> |
GridCacheProxyImpl.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<Object> |
GridCacheAdapter.readThroughAllAsync(Collection<? extends K> keys,
boolean reload,
GridCacheTxEx<K,V> tx,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId,
GridBiInClosure<K,V> vis) |
GridFuture<Object> |
GridCacheExplicitLockSpan.releaseFuture()
Gets span release future.
|
GridFuture<?> |
GridCacheProjectionImpl.reloadAllAsync()
Asynchronously reloads all specified entries from underlying
persistent storage.
|
GridFuture<?> |
GridCacheAdapter.reloadAllAsync()
Asynchronously reloads all specified entries from underlying
persistent storage.
|
GridFuture<?> |
GridCacheProxyImpl.reloadAllAsync()
Asynchronously reloads all specified entries from underlying
persistent storage.
|
GridFuture<?> |
GridCacheProjectionImpl.reloadAllAsync(Collection<? extends K> keys)
Asynchronously reloads all specified entries from underlying
persistent storage.
|
GridFuture<?> |
GridCacheAdapter.reloadAllAsync(Collection<? extends K> keys)
Asynchronously reloads all specified entries from underlying
persistent storage.
|
GridFuture<?> |
GridCacheProxyImpl.reloadAllAsync(Collection<? extends K> keys)
Asynchronously reloads all specified entries from underlying
persistent storage.
|
GridFuture<Map<K,V>> |
GridCacheAdapter.reloadAllAsync(Collection<? extends K> keys,
boolean ret,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<?> |
GridCacheAdapter.reloadAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<?> |
GridCacheAdapter.reloadAllAsync(GridPredicate<GridCacheEntry<K,V>> filter) |
GridFuture<V> |
GridCacheEvictionEntry.reloadAsync()
This method has the same semantic as
GridCacheProjection.reloadAsync(Object) method. |
GridFuture<V> |
GridCacheEntryImpl.reloadAsync()
This method has the same semantic as
GridCacheProjection.reloadAsync(Object) method. |
GridFuture<V> |
GridCacheFilterEvaluationEntry.reloadAsync()
This method has the same semantic as
GridCacheProjection.reloadAsync(Object) method. |
GridFuture<V> |
GridCacheProjectionImpl.reloadAsync(K key)
Asynchronously reloads a single key from persistent storage.
|
GridFuture<V> |
GridCacheAdapter.reloadAsync(K key)
Asynchronously reloads a single key from persistent storage.
|
GridFuture<V> |
GridCacheProxyImpl.reloadAsync(K key)
Asynchronously reloads a single key from persistent storage.
|
GridFuture<V> |
GridCacheAdapter.reloadAsync(K key,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalAdapter.removeAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean implicit,
boolean retval,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalEx.removeAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean implicit,
boolean retval,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<?> |
GridCacheAdapter.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridCacheProjectionImpl.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridCacheProxyImpl.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridCacheProjectionImpl.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<?> |
GridCacheAdapter.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<?> |
GridCacheProxyImpl.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<?> |
GridCacheProjectionEx.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridFuture<?> |
GridCacheProjectionImpl.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridFuture<?> |
GridCacheAdapter.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridFuture<?> |
GridCacheProxyImpl.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridFuture<?> |
GridCacheTxLocalAdapter.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap) |
GridFuture<?> |
GridCacheTxLocalEx.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap) |
GridFuture<V> |
GridCacheFilterEvaluationEntry.removeAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.removeAsync(Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheEvictionEntry.removeAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.removeAsync(Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheEntryImpl.removeAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.removeAsync(Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheProjectionEx.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheProjectionImpl.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheAdapter.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheProxyImpl.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheTxLocalAdapter.removeAsync(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<V> |
GridCacheTxLocalEx.removeAsync(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<V> |
GridCacheAdapter.removeAsync(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes given key mapping from cache.
|
GridFuture<V> |
GridCacheProjectionImpl.removeAsync(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mapping from cache.
|
GridFuture<V> |
GridCacheProxyImpl.removeAsync(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mapping from cache.
|
GridFuture<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.
|
GridFuture<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.
|
GridFuture<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.
|
GridFuture<Boolean> |
GridCacheEvictionEntry.removeAsync(V val)
This method has the same semantic as
GridCacheProjection.removeAsync(Object, Object) method. |
GridFuture<Boolean> |
GridCacheEntryImpl.removeAsync(V val)
This method has the same semantic as
GridCacheProjection.removeAsync(Object, Object) method. |
GridFuture<Boolean> |
GridCacheFilterEvaluationEntry.removeAsync(V val)
This method has the same semantic as
GridCacheProjection.removeAsync(Object, Object) method. |
GridFuture<?> |
GridCacheMvccManager.removeAtomicFuture(GridCacheVersion futVer) |
GridFuture<Boolean> |
GridCacheFilterEvaluationEntry.removexAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.removexAsync(Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheEvictionEntry.removexAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.removexAsync(Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheEntryImpl.removexAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.removexAsync(Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheProjectionEx.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheProjectionImpl.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheAdapter.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheProxyImpl.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheTxLocalAdapter.removexAsync(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<Boolean> |
GridCacheTxLocalEx.removexAsync(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<Boolean> |
GridCacheAdapter.removexAsync(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes given key mapping from cache.
|
GridFuture<Boolean> |
GridCacheProjectionImpl.removexAsync(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mapping from cache.
|
GridFuture<Boolean> |
GridCacheProxyImpl.removexAsync(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mapping from cache.
|
GridFuture<GridCacheReturn<V>> |
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.
|
GridFuture<GridCacheReturn<V>> |
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.
|
GridFuture<GridCacheReturn<V>> |
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.
|
GridFuture<GridCacheReturn<V>> |
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.
|
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalAdapter.removexAsync0(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalEx.removexAsync0(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<V> |
GridCacheProjectionImpl.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if if there is a previous mapping for it.
|
GridFuture<V> |
GridCacheAdapter.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if if there is a previous mapping for it.
|
GridFuture<V> |
GridCacheProxyImpl.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if if there is a previous mapping for it.
|
GridFuture<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. |
GridFuture<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. |
GridFuture<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. |
GridFuture<V> |
GridCacheEvictionEntry.replaceAsync(V val)
This method has the same semantic as
GridCacheProjection.replaceAsync(Object, Object) method. |
GridFuture<V> |
GridCacheEntryImpl.replaceAsync(V val)
This method has the same semantic as
GridCacheProjection.replaceAsync(Object, Object) method. |
GridFuture<V> |
GridCacheFilterEvaluationEntry.replaceAsync(V val)
This method has the same semantic as
GridCacheProjection.replaceAsync(Object, Object) method. |
GridFuture<Boolean> |
GridCacheEvictionEntry.replaceAsync(V oldVal,
V newVal)
This method has the same semantic as
GridCacheProjection.replaceAsync(Object, Object, Object) method. |
GridFuture<Boolean> |
GridCacheEntryImpl.replaceAsync(V oldVal,
V newVal)
This method has the same semantic as
GridCacheProjection.replaceAsync(Object, Object, Object) method. |
GridFuture<Boolean> |
GridCacheFilterEvaluationEntry.replaceAsync(V oldVal,
V newVal)
This method has the same semantic as
GridCacheProjection.replaceAsync(Object, Object, Object) method. |
GridFuture<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.
|
GridFuture<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.
|
GridFuture<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.
|
GridFuture<GridCacheReturn<V>> |
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. |
GridFuture<GridCacheReturn<V>> |
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. |
GridFuture<GridCacheReturn<V>> |
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. |
GridFuture<GridCacheReturn<V>> |
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. |
GridFuture<Boolean> |
GridCacheEvictionEntry.replacexAsync(V val)
This method has the same semantic as
GridCacheProjection.replacexAsync(Object, Object) method. |
GridFuture<Boolean> |
GridCacheEntryImpl.replacexAsync(V val)
This method has the same semantic as
GridCacheProjection.replacexAsync(Object, Object) method. |
GridFuture<Boolean> |
GridCacheFilterEvaluationEntry.replacexAsync(V val)
This method has the same semantic as
GridCacheProjection.replacexAsync(Object, Object) method. |
GridFuture<Object> |
GridCachePreloaderAdapter.request(Collection<? extends K> keys,
long topVer)
Requests that preloader sends the request for the key.
|
GridFuture<Object> |
GridCachePreloader.request(Collection<? extends K> keys,
long topVer)
Requests that preloader sends the request for the key.
|
GridFuture<GridCacheTx> |
GridCacheTxEx.rollbackAsync()
TODO-gg-4004 Put rollback async on public API?
Asynchronously rollback this transaction.
|
GridFuture<V> |
GridCacheFilterEvaluationEntry.setAsync(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.putAsync(Object, Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheEvictionEntry.setAsync(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.putAsync(Object, Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheEntryImpl.setAsync(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.putAsync(Object, Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheEvictionEntry.setIfAbsentAsync(V val)
This method has the same semantic as
GridCacheProjection.putIfAbsentAsync(Object, Object) method. |
GridFuture<V> |
GridCacheEntryImpl.setIfAbsentAsync(V val)
This method has the same semantic as
GridCacheProjection.putIfAbsentAsync(Object, Object) method. |
GridFuture<V> |
GridCacheFilterEvaluationEntry.setIfAbsentAsync(V val)
This method has the same semantic as
GridCacheProjection.putIfAbsentAsync(Object, Object) method. |
GridFuture<Boolean> |
GridCacheFilterEvaluationEntry.setxAsync(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.putxAsync(Object, Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheEvictionEntry.setxAsync(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.putxAsync(Object, Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheEntryImpl.setxAsync(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.putxAsync(Object, Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheEvictionEntry.setxIfAbsentAsync(V val)
This method has the same semantic as
GridCacheProjection.putxIfAbsentAsync(Object, Object) method. |
GridFuture<Boolean> |
GridCacheEntryImpl.setxIfAbsentAsync(V val)
This method has the same semantic as
GridCacheProjection.putxIfAbsentAsync(Object, Object) method. |
GridFuture<Boolean> |
GridCacheFilterEvaluationEntry.setxIfAbsentAsync(V val)
This method has the same semantic as
GridCacheProjection.putxIfAbsentAsync(Object, Object) method. |
GridFuture<?> |
GridCachePreloaderAdapter.startFuture() |
GridFuture<?> |
GridCachePreloader.startFuture() |
GridFuture<?> |
GridCachePreloaderAdapter.syncFuture() |
GridFuture<?> |
GridCachePreloader.syncFuture() |
GridFuture<?> |
GridCacheProjectionImpl.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
GridFuture<?> |
GridCacheAdapter.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
GridFuture<?> |
GridCacheProxyImpl.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
GridFuture<?> |
GridCacheTxLocalAdapter.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> map) |
GridFuture<?> |
GridCacheTxLocalEx.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> map) |
GridFuture<?> |
GridCacheProjectionImpl.transformAllAsync(Set<? extends K> keys,
GridClosure<V,V> transformer)
Stores result of applying the specified transform closure to previous values associated
with the specified keys in cache.
|
GridFuture<?> |
GridCacheAdapter.transformAllAsync(Set<? extends K> keys,
GridClosure<V,V> transformer)
Stores result of applying the specified transform closure to previous values associated
with the specified keys in cache.
|
GridFuture<?> |
GridCacheProxyImpl.transformAllAsync(Set<? extends K> keys,
GridClosure<V,V> transformer)
Stores result of applying the specified transform closure to previous values associated
with the specified keys in cache.
|
GridFuture<?> |
GridCacheEvictionEntry.transformAsync(GridClosure<V,V> transformer)
This method has the same semantic as
GridCacheProjection.transformAsync(Object, GridClosure) method. |
GridFuture<?> |
GridCacheEntryImpl.transformAsync(GridClosure<V,V> transformer)
This method has the same semantic as
GridCacheProjection.transformAsync(Object, GridClosure) method. |
GridFuture<?> |
GridCacheFilterEvaluationEntry.transformAsync(GridClosure<V,V> transformer)
This method has the same semantic as
GridCacheProjection.transformAsync(Object, GridClosure) method. |
GridFuture<?> |
GridCacheProjectionImpl.transformAsync(K key,
GridClosure<V,V> transformer)
Stores result of applying
transformer closure to the previous value associated with
given key in cache. |
GridFuture<?> |
GridCacheAdapter.transformAsync(K key,
GridClosure<V,V> transformer)
Stores result of applying
transformer closure to the previous value associated with
given key in cache. |
GridFuture<?> |
GridCacheProxyImpl.transformAsync(K key,
GridClosure<V,V> transformer)
Stores result of applying
transformer closure to the previous value associated with
given key in cache. |
GridFuture<?> |
GridCacheProjectionEx.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<?> |
GridCacheProjectionImpl.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<?> |
GridCacheAdapter.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<?> |
GridCacheProxyImpl.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheTxLocalAdapter.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> cached,
long ttl) |
GridFuture<Boolean> |
GridCacheTxLocalEx.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> cached,
long ttl) |
abstract GridFuture<Boolean> |
GridCacheAdapter.txLockAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
boolean invalidate,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<V> |
GridCacheContext.wrapClone(GridFuture<V> f) |
GridFuture<Map<K,V>> |
GridCacheContext.wrapCloneMap(GridFuture<Map<K,V>> f) |
| Modifier and Type | Method and Description |
|---|---|
GridBiClosure<Collection<K>,Boolean,GridFuture<Object>> |
GridCacheAdapter.beforePessimisticLock() |
static GridInClosure<GridFuture<?>> |
GridCacheUtils.errorLogger(GridLogger log,
Class<? extends Exception>... excl) |
<T> Collection<? extends GridFuture<T>> |
GridCacheMvccManager.futures(GridCacheVersion ver)
Gets all futures for given lock version, possibly empty collection.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheAdapter.FutureHolder.future(GridFuture fut)
Sets future.
|
protected void |
GridCacheAdapter.saveFuture(GridCacheAdapter.FutureHolder holder,
GridFuture<?> fut)
Saves future in thread local holder and adds listener
that will clear holder when future is finished.
|
GridFuture<V> |
GridCacheContext.wrapClone(GridFuture<V> f) |
GridFuture<Map<K,V>> |
GridCacheContext.wrapCloneMap(GridFuture<Map<K,V>> f) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheAdapter.beforePessimisticLock(GridBiClosure<Collection<K>,Boolean,GridFuture<Object>> beforePessimisticLock)
Sets callback that will be invoked before keys are locked.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheOptimisticCheckPreparedTxFuture<K,V>
Future verifying that all remote transactions related to some
optimistic transaction were prepared.
|
class |
GridCachePessimisticCheckCommittedTxFuture<K,V>
Future verifying that all remote transactions related to some
optimistic transaction were prepared.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<?> |
GridCacheTxFinishSync.awaitAckAsync(UUID nodeId,
long threadId) |
GridFuture<GridCacheTx> |
GridDistributedTxRemoteAdapter.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
protected abstract GridFuture<Boolean> |
GridDistributedCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridDistributedCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
GridFuture<GridCacheTxEx<K,V>> |
GridDistributedTxRemoteAdapter.prepareAsync()
Prepare stage.
|
GridFuture<GridCacheTx> |
GridDistributedTxRemoteAdapter.rollbackAsync()
TODO-gg-4004 Put rollback async on public API?
Asynchronously rollback this transaction.
|
GridFuture<Boolean> |
GridDistributedCacheAdapter.txLockAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
boolean isInvalidate,
GridPredicate<GridCacheEntry<K,V>>[] 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<K,V>
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 |
|---|---|
GridFuture<Boolean> |
GridDhtTxLocalAdapter.addEntry(long msgId,
GridCacheTxEntry<K,V> e) |
protected abstract GridFuture<Boolean> |
GridDhtTxLocalAdapter.addReader(long msgId,
GridDhtCacheEntry<K,V> cached,
GridCacheTxEntry<K,V> entry,
long topVer)
Adds reader to cached entry.
|
protected GridFuture<Boolean> |
GridDhtTxLocal.addReader(long msgId,
GridDhtCacheEntry<K,V> cached,
GridCacheTxEntry<K,V> entry,
long topVer)
Adds reader to cached entry.
|
GridFuture<Boolean> |
GridDhtCacheEntry.addReader(UUID nodeId,
long msgId,
long topVer) |
GridFuture<GridCacheTx> |
GridDhtTxLocal.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
GridFuture<GridCacheTx> |
GridDhtTransactionalCacheAdapter.commitTx(UUID nodeId,
GridNearTxFinishRequest<K,V> req) |
GridFuture<GridCacheTxEx<K,V>> |
GridDhtTxLocal.future() |
GridFuture<Map<K,V>> |
GridDhtCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method is used internally.
|
GridFuture<Boolean> |
GridDhtTransactionalCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> txx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridNearLockResponse<K,V>> |
GridDhtTransactionalCacheAdapter.lockAllAsync(GridNode nearNode,
GridNearLockRequest<K,V> req,
GridPredicate<GridCacheEntry<K,V>>[] filter0) |
GridFuture<?> |
GridDhtCacheAdapter.multiUpdateFinishFuture(long topVer)
Creates multi update finish future.
|
GridFuture<GridCacheTxEx<K,V>> |
GridDhtTxLocal.prepareAsync()
Prepare stage.
|
GridFuture<GridCacheTxEx<K,V>> |
GridDhtTxLocal.prepareAsync(Iterable<GridCacheTxEntry<K,V>> reads,
Iterable<GridCacheTxEntry<K,V>> writes,
Map<K,GridCacheVersion> verMap,
long msgId,
GridUuid nearMiniId,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
Collection<UUID> lastBackups)
Prepares next batch of entries in dht transaction.
|
GridFuture<GridCacheTxEx<K,V>> |
GridDhtTransactionalCacheAdapter.prepareTx(GridNode nearNode,
GridNearTxPrepareRequest<K,V> req) |
GridFuture<GridCacheTx> |
GridDhtTxLocal.rollbackAsync()
TODO-gg-4004 Put rollback async on public API?
Asynchronously rollback this transaction.
|
GridFuture<GridCacheTx> |
GridDhtTransactionalCacheAdapter.rollbackTx(UUID nodeId,
GridNearTxFinishRequest<K,V> req) |
| Constructor and Description |
|---|
GridDhtEmbeddedFuture(GridFuture<B> embedded,
GridBiClosure<B,Exception,GridFuture<A>> c,
GridKernalContext ctx) |
GridDhtEmbeddedFuture(GridKernalContext ctx,
GridFuture<B> embedded,
GridBiClosure<B,Exception,A> c) |
GridDhtEmbeddedFuture(GridKernalContext ctx,
GridFuture<B> embedded,
GridBiClosure<B,Exception,A> c,
Collection<Integer> invalidParts) |
| Constructor and Description |
|---|
GridDhtEmbeddedFuture(GridFuture<B> embedded,
GridBiClosure<B,Exception,GridFuture<A>> c,
GridKernalContext ctx) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtAtomicUpdateFuture<K,V>
DHT atomic cache backup update future.
|
class |
GridNearAtomicUpdateFuture<K,V>
DHT atomic cache near update future.
|
| Modifier and Type | Method and Description |
|---|---|
protected <T> GridFuture<T> |
GridDhtAtomicCache.asyncOp(CO<GridFuture<T>> op) |
GridFuture<Map<K,V>> |
GridDhtAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method is used internally.
|
protected GridFuture<Boolean> |
GridDhtAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<?> |
GridDhtAtomicCache.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<?> |
GridDhtAtomicCache.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data asynchronously.
|
GridFuture<V> |
GridDhtAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridDhtAtomicCache.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<Boolean> |
GridDhtAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridDhtAtomicCache.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<?> |
GridDhtAtomicCache.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridDhtAtomicCache.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<?> |
GridDhtAtomicCache.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridFuture<V> |
GridDhtAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<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.
|
GridFuture<Boolean> |
GridDhtAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<GridCacheReturn<V>> |
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.
|
GridFuture<V> |
GridDhtAtomicCache.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if if there is a previous mapping for it.
|
GridFuture<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. |
GridFuture<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.
|
GridFuture<GridCacheReturn<V>> |
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. |
GridFuture<?> |
GridDhtAtomicCache.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
GridFuture<?> |
GridDhtAtomicCache.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
| Modifier and Type | Method and Description |
|---|---|
protected <T> GridFuture<T> |
GridDhtAtomicCache.asyncOp(CO<GridFuture<T>> op) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtColocatedLockFuture<K,V>
Colocated cache lock future.
|
class |
GridDhtColocatedTxFinishFuture<K,V>
Colocated tx finish future.
|
class |
GridDhtColocatedTxPrepareFuture<K,V>
Prepare future for colocated cache.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridFuture<Boolean> |
GridDhtColocatedTxLocal.addReader(long msgId,
GridDhtCacheEntry<K,V> cached,
GridCacheTxEntry<K,V> entry,
long topVer)
Adds reader to cached entry.
|
GridFuture<GridCacheTx> |
GridDhtColocatedTxLocal.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
GridFuture<GridCacheTxEx<K,V>> |
GridDhtColocatedTxLocal.future() |
GridFuture<Map<K,V>> |
GridDhtColocatedCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method is used internally.
|
GridFuture<Map<K,V>> |
GridDhtColocatedCache.loadAsync(Collection<? extends K> keys,
boolean reload,
boolean forcePrimary,
long topVer,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridDhtColocatedTxLocal.loadMissing(boolean async,
Collection<? extends K> keys,
GridBiInClosure<K,V> c) |
GridFuture<Boolean> |
GridDhtColocatedCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This is an entry point to pessimistic locking within transaction.
|
GridFuture<GridCacheTxEx<K,V>> |
GridDhtColocatedTxLocal.prepareAsync()
Prepare stage.
|
GridFuture<GridCacheTxEx<K,V>> |
GridDhtColocatedTxLocal.prepareAsyncLocal(Collection<GridCacheTxEntry<K,V>> reads,
Collection<GridCacheTxEntry<K,V>> writes,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
Collection<UUID> lastBackups)
Prepares next batch of entries in dht transaction.
|
GridFuture<GridCacheTxEx<K,V>> |
GridDhtColocatedCache.prepareTxLocally(GridDhtColocatedTxLocal<K,V> tx,
Collection<GridCacheTxEntry<K,V>> reads,
Collection<GridCacheTxEntry<K,V>> writes,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
Collection<UUID> lastBackups) |
GridFuture<GridCacheTx> |
GridDhtColocatedTxLocal.rollbackAsync()
TODO-gg-4004 Put rollback async on public API?
Asynchronously rollback this transaction.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtForceKeysFuture<K,V>
Force keys request future.
|
class |
GridDhtPartitionsExchangeFuture<K,V>
Future for exchanging partition maps.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<?> |
GridDhtPreloader.startFuture() |
GridFuture<?> |
GridDhtPreloader.syncFuture() |
| Modifier and Type | Method and Description |
|---|---|
List<GridFuture<?>> |
GridDhtPreloader.exchangeFutures() |
| 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 |
|---|---|
GridFuture<?> |
GridNearCacheAdapter.drStateTransfer(Collection<Byte> dataCenterIds)
Starts full state transfer.
|
protected GridFuture<Map<K,V>> |
GridNearAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<Map<K,V>> |
GridNearTransactionalCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Map<K,V>> |
GridNearCacheAdapter.loadAsync(GridCacheTxEx tx,
Collection<? extends K> keys,
boolean reload,
boolean forcePrimary,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId) |
GridFuture<?> |
GridNearCacheAdapter.loadCacheAsync(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Asynchronously delegates to
GridCacheStore.loadCache(GridBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
protected GridFuture<Boolean> |
GridNearTransactionalCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
protected GridFuture<Boolean> |
GridNearAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<?> |
GridNearAtomicCache.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<?> |
GridNearAtomicCache.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data asynchronously.
|
GridFuture<V> |
GridNearAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridNearAtomicCache.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<Boolean> |
GridNearAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridNearAtomicCache.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<Object> |
GridNearCacheAdapter.readThroughAllAsync(Collection<? extends K> keys,
boolean reload,
GridCacheTxEx<K,V> tx,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId,
GridBiInClosure<K,V> vis) |
GridFuture<?> |
GridNearCacheAdapter.reloadAllAsync()
Asynchronously reloads all specified entries from underlying
persistent storage.
|
GridFuture<?> |
GridNearCacheAdapter.reloadAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<?> |
GridNearCacheAdapter.reloadAllAsync(GridPredicate<GridCacheEntry<K,V>> filter) |
GridFuture<?> |
GridNearAtomicCache.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridNearAtomicCache.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<?> |
GridNearAtomicCache.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridFuture<V> |
GridNearAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<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.
|
GridFuture<Boolean> |
GridNearAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<GridCacheReturn<V>> |
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.
|
GridFuture<V> |
GridNearAtomicCache.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if if there is a previous mapping for it.
|
GridFuture<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. |
GridFuture<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.
|
GridFuture<GridCacheReturn<V>> |
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. |
GridFuture<?> |
GridNearAtomicCache.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
GridFuture<?> |
GridNearAtomicCache.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
| Modifier and Type | Method and Description |
|---|---|
GridBiClosure<Collection<K>,Boolean,GridFuture<Object>> |
GridNearCacheAdapter.beforePessimisticLock() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearCacheAdapter.beforePessimisticLock(GridBiClosure<Collection<K>,Boolean,GridFuture<Object>> beforePessimisticLock)
Sets callback that will be invoked before keys are locked.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<?> |
GridCacheDrManager.stateTransfer(Collection<Byte> dataCenterIds)
Initiate state transfer.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<?> |
GridOsCacheDrManager.stateTransfer(Collection<Byte> dataCenterIds)
Initiate state transfer.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridLocalLockFuture<K,V>
Cache lock future.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<Boolean> |
GridLocalCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridLocalCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
GridFuture<Boolean> |
GridLocalCache.txLockAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
boolean invalidate,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
protected GridFuture |
GridLocalAtomicCache.asyncOp(Callable<?> op) |
GridFuture<Map<K,V>> |
GridLocalAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridLocalAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
GridFuture<?> |
GridLocalAtomicCache.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<V> |
GridLocalAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridLocalAtomicCache.putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<Boolean> |
GridLocalAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridLocalAtomicCache.putxIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
GridFuture<?> |
GridLocalAtomicCache.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridLocalAtomicCache.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<V> |
GridLocalAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<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.
|
GridFuture<Boolean> |
GridLocalAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<GridCacheReturn<V>> |
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.
|
GridFuture<V> |
GridLocalAtomicCache.replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if if there is a previous mapping for it.
|
GridFuture<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. |
GridFuture<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.
|
GridFuture<GridCacheReturn<V>> |
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. |
GridFuture<?> |
GridLocalAtomicCache.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
GridFuture<?> |
GridLocalAtomicCache.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridLocalAtomicCache.txLockAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
boolean invalidate,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheDistributedFieldsQueryFuture
Distributed fields query future.
|
class |
GridCacheDistributedQueryFuture<K,V,R>
Distributed query future.
|
class |
GridCacheFieldsQueryErrorFuture
Error future for fields query.
|
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 |
|---|---|
GridFuture<List<GridIndexingFieldMetadata>> |
GridCacheLocalFieldsQueryFuture.metadata() |
GridFuture<List<GridIndexingFieldMetadata>> |
GridCacheFieldsQueryErrorFuture.metadata() |
GridFuture<List<GridIndexingFieldMetadata>> |
GridCacheQueryMetadataAware.metadata() |
GridFuture<List<GridIndexingFieldMetadata>> |
GridCacheDistributedFieldsQueryFuture.metadata() |
GridFuture<?> |
GridCacheQueryManager.rebuildAllIndexes()
Rebuilds all search indexes of all types.
|
GridFuture<?> |
GridCacheQueriesImpl.rebuildAllIndexes()
Forces this cache to rebuild search indexes of all types.
|
GridFuture<?> |
GridCacheQueriesProxy.rebuildAllIndexes()
Forces this cache to rebuild search indexes of all types.
|
GridFuture<?> |
GridCacheQueryManager.rebuildIndexes(Class<?> valType)
Rebuilds all search indexes of given value type.
|
GridFuture<?> |
GridCacheQueriesImpl.rebuildIndexes(Class<?> cls)
Forces this cache to rebuild all search indexes of given value type.
|
GridFuture<?> |
GridCacheQueriesProxy.rebuildIndexes(Class<?> cls)
Forces this cache to rebuild all search indexes of given value type.
|
| Modifier and Type | Method and Description |
|---|---|
<R> GridFuture<R> |
GridClosureProcessor.affinityCall(String cacheName,
Object affKey,
Callable<R> job,
Collection<GridNode> nodes) |
GridFuture<?> |
GridClosureProcessor.affinityRun(String cacheName,
Object affKey,
Runnable job,
Collection<GridNode> nodes) |
<T,R> GridFuture<Collection<R>> |
GridClosureProcessor.broadcast(GridClosure<T,R> job,
T arg,
Collection<GridNode> nodes) |
<T,R> GridFuture<Collection<R>> |
GridClosureProcessor.callAsync(GridClosure<T,R> job,
Collection<? extends T> args,
Collection<GridNode> nodes) |
<T,R> GridFuture<R> |
GridClosureProcessor.callAsync(GridClosure<T,R> job,
T arg,
Collection<GridNode> nodes) |
<T,R1,R2> GridFuture<R2> |
GridClosureProcessor.callAsync(GridClosure<T,R1> job,
Collection<? extends T> args,
GridReducer<R1,R2> rdc,
Collection<GridNode> nodes) |
<R> GridFuture<R> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Callable<R> job,
Collection<GridNode> nodes) |
<R> GridFuture<R> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Callable<R> job,
Collection<GridNode> nodes,
boolean sys) |
<R> GridFuture<Collection<R>> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Collection<? extends Callable<R>> jobs,
Collection<GridNode> nodes) |
<R> GridFuture<Collection<R>> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Collection<? extends Callable<R>> jobs,
Collection<GridNode> nodes,
boolean sys) |
<R> GridFuture<R> |
GridClosureProcessor.callAsyncNoFailover(GridClosureCallMode mode,
Callable<R> job,
Collection<GridNode> nodes,
boolean sys) |
<R> GridFuture<Collection<R>> |
GridClosureProcessor.callAsyncNoFailover(GridClosureCallMode mode,
Collection<? extends Callable<R>> jobs,
Collection<GridNode> nodes,
boolean sys) |
<R> GridFuture<R> |
GridClosureProcessor.callLocalSafe(Callable<R> c)
Executes closure on system pool.
|
<R> GridFuture<R> |
GridClosureProcessor.callLocalSafe(Callable<R> c,
boolean sys)
Executes closure on system pool.
|
<R> GridFuture<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). |
<R1,R2> GridFuture<R2> |
GridClosureProcessor.forkjoinAsync(GridClosureCallMode mode,
Collection<? extends Callable<R1>> jobs,
GridReducer<R1,R2> rdc,
Collection<GridNode> nodes) |
GridFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Collection<? extends Runnable> jobs,
Collection<GridNode> nodes) |
GridFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Collection<? extends Runnable> jobs,
Collection<GridNode> nodes,
boolean sys) |
GridFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Runnable job,
Collection<GridNode> nodes) |
GridFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Runnable job,
Collection<GridNode> nodes,
boolean sys) |
GridFuture<?> |
GridClosureProcessor.runLocalSafe(Runnable c)
Executes closure on system pool.
|
GridFuture<?> |
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). |
GridFuture<?> |
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 |
|---|---|
GridFuture<UUID> |
GridContinuousProcessor.startRoutine(GridContinuousHandler hnd,
int bufSize,
long interval,
boolean autoUnsubscribe,
GridPredicate<GridNode> prjPred) |
GridFuture<?> |
GridContinuousProcessor.stopRoutine(UUID routineId) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<?> |
GridDataLoaderImpl.addData(Collection<? extends Map.Entry<K,V>> entries)
Adds data for loading on remote node.
|
GridFuture<?> |
GridDataLoaderImpl.addData(K key,
V val)
Adds data for loading on remote node.
|
GridFuture<?> |
GridDataLoaderImpl.addData(Map.Entry<K,V> entry)
Adds data for loading on remote node.
|
GridFuture<?> |
GridDataLoaderImpl.addData(Map<K,V> entries)
Adds data for loading on remote node.
|
GridFuture<?> |
GridDataLoaderImpl.future()
Gets future for this loading process.
|
GridFuture<?> |
GridDataLoaderImpl.removeData(K key)
Adds key for removal on remote node.
|
| Modifier and Type | Method and Description |
|---|---|
abstract GridFuture<Boolean> |
GridEmailProcessorAdapter.schedule(String subj,
String body,
boolean html)
Schedules sending of given email to all admin emails, if any.
|
GridFuture<Boolean> |
GridNoopEmailProcessor.schedule(String subj,
String body,
boolean html)
Schedules sending of given email to all admin emails, if any.
|
abstract GridFuture<Boolean> |
GridEmailProcessorAdapter.schedule(String subj,
String body,
boolean html,
Collection<String> addrs)
Schedules sending of given email.
|
GridFuture<Boolean> |
GridNoopEmailProcessor.schedule(String subj,
String body,
boolean html,
Collection<String> addrs)
Schedules sending of given email.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<GridRestResponse> |
GridRestProtocolHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<GridRestResponse> |
GridRestCommandHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<GridRestResponse> |
GridCacheCommandHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<GridRestResponse> |
GridLogCommandHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<GridRestResponse> |
GridTaskCommandHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<GridRestResponse> |
GridTopologyCommandHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<GridRestResponse> |
GridVersionCommandHandler.handleAsync(GridRestRequest req) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridStreamerStageExecutionFuture
Streamer execution future.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<UUID> |
GridMessaging.remoteListen(Object topic,
GridBiPredicate<UUID,?> p)
Adds a message listener for a given topic to all nodes in the projection (possibly including
this node if it belongs to the projection as well).
|
GridFuture<?> |
GridMessaging.stopRemoteListen(UUID opId)
Unregisters all listeners identified with provided operation ID on all nodes in this projection.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
GridSchedulerFuture<R>
Future for cron-based scheduled execution.
|
| Modifier and Type | Method and Description |
|---|---|
<R> GridFuture<R> |
GridScheduler.callLocal(Callable<R> c)
Executes given callable on internal system thread pool asynchronously.
|
GridFuture<?> |
GridScheduler.runLocal(Runnable r)
Executes given closure on internal system thread pool asynchronously.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
GridUtils.asyncLogError(GridFuture<?> f,
GridLogger 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 |
GridFinishedFutureEx<T>
Future that is completed at creation time.
|
class |
GridFutureAdapter<R>
Future adapter.
|
class |
GridFutureAdapterEx<R>
Future adapter without kernal context.
|
| Modifier and Type | Method and Description |
|---|---|
<T> GridFuture<T> |
GridFutureAdapter.chain(GridClosure<? super GridFuture<R>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
<T> GridFuture<T> |
GridFutureAdapterEx.chain(GridClosure<? super GridFuture<R>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
<R> GridFuture<R> |
GridFinishedFutureEx.chain(GridClosure<? super GridFuture<T>,R> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
<R> GridFuture<R> |
GridFinishedFuture.chain(GridClosure<? super GridFuture<T>,R> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridFuture<T>> |
GridCompoundFuture.futures()
Gets collection of futures.
|
Collection<GridFuture<T>> |
GridCompoundFuture.pending()
Gets pending (unfinished) futures.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCompoundFuture.add(GridFuture<T> fut)
Adds a future to this compound future.
|
void |
GridCompoundFuture.addAll(GridFuture<T>... futs)
Adds futures to this compound future.
|
void |
GridFutureChainListener.apply(GridFuture<T> t)
Closure body.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCompoundFuture.addAll(Iterable<GridFuture<T>> futs)
Adds futures to this compound future.
|
<T> GridFuture<T> |
GridFutureAdapter.chain(GridClosure<? super GridFuture<R>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
<T> GridFuture<T> |
GridFutureAdapterEx.chain(GridClosure<? super GridFuture<R>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
<R> GridFuture<R> |
GridFinishedFutureEx.chain(GridClosure<? super GridFuture<T>,R> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
<R> GridFuture<R> |
GridFinishedFuture.chain(GridClosure<? super GridFuture<T>,R> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
void |
GridFutureAdapter.listenAsync(GridInClosure<? super GridFuture<R>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridFutureAdapterEx.listenAsync(GridInClosure<? super GridFuture<R>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridFinishedFutureEx.listenAsync(GridInClosure<? super GridFuture<T>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridFinishedFuture.listenAsync(GridInClosure<? super GridFuture<T>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Constructor and Description |
|---|
GridEmbeddedFuture(boolean syncNotify,
GridFuture<B> embedded,
GridBiClosure<B,Exception,GridFuture<A>> c,
GridKernalContext ctx)
Embeds futures.
|
GridEmbeddedFuture(GridFuture<B> embedded,
GridBiClosure<B,Exception,GridFuture<A>> c,
GridKernalContext ctx)
Embeds futures.
|
GridEmbeddedFuture(GridKernalContext ctx,
GridFuture<B> embedded,
GridBiClosure<B,Exception,A> c) |
GridEmbeddedFuture(GridKernalContext ctx,
GridFuture<B> embedded,
GridBiClosure<B,Exception,GridFuture<A>> c1,
GridBiClosure<A,Exception,A> c2)
Embeds futures.
|
| Constructor and Description |
|---|
GridCompoundFuture(GridKernalContext ctx,
GridReducer<T,R> rdc,
Iterable<GridFuture<T>> futs) |
GridCompoundIdentityFuture(GridKernalContext ctx,
GridReducer<T,T> rdc,
Iterable<GridFuture<T>> futs) |
GridEmbeddedFuture(boolean syncNotify,
GridFuture<B> embedded,
GridBiClosure<B,Exception,GridFuture<A>> c,
GridKernalContext ctx)
Embeds futures.
|
GridEmbeddedFuture(GridFuture<B> embedded,
GridBiClosure<B,Exception,GridFuture<A>> c,
GridKernalContext ctx)
Embeds futures.
|
GridEmbeddedFuture(GridKernalContext ctx,
GridFuture<B> embedded,
GridBiClosure<B,Exception,GridFuture<A>> c1,
GridBiClosure<A,Exception,A> c2)
Embeds futures.
|
GridFutureChainListener(GridKernalContext ctx,
GridFutureAdapter<R> fut,
GridClosure<? super GridFuture<T>,R> doneCb)
Constructs chain listener.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> GridFuture<T> |
GridFunc.awaitOne(GridFuture<T>... futs)
Waits for one completed future from passed and returns it.
|
static <T> GridFuture<T> |
GridFunc.awaitOne(Iterable<GridFuture<T>> futs)
Waits for the first completed future from passed and returns it.
|
| Modifier and Type | Method and Description |
|---|---|
static GridPredicate<GridFuture<?>> |
GridFunc.finishedFutures()
Returns predicate for filtering finished futures.
|
static <T> GridClosure<GridFuture<T>,Future<T>> |
GridFunc.future()
Gets closure that converts
GridFuture to Future. |
static GridPredicate<GridFuture<?>> |
GridFunc.unfinishedFutures()
Returns predicate for filtering unfinished futures.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> Future<T> |
GridFunc.as(GridFuture<T> fut)
Converts given object with interface
GridFuture into an object implementing Future. |
static <T> void |
GridFunc.awaitAll(GridFuture<T>... futs)
Waits until all passed futures will be executed.
|
static <T> GridFuture<T> |
GridFunc.awaitOne(GridFuture<T>... futs)
Waits for one completed future from passed and returns it.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> void |
GridFunc.awaitAll(Collection<GridFuture<T>> futs)
Waits until all passed futures will be executed.
|
static <T> void |
GridFunc.awaitAll(long timeout,
Collection<GridFuture<T>> futs)
Waits until all passed futures will be executed.
|
static <T,R> R |
GridFunc.awaitAll(long timeout,
GridReducer<T,R> rdc,
Collection<GridFuture<T>> futs)
Awaits for all futures to complete and optionally reduces all results into one.
|
static <T> GridFuture<T> |
GridFunc.awaitOne(Iterable<GridFuture<T>> futs)
Waits for the first completed future from passed and returns it.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
X.waitAll(Iterable<GridFuture<?>> futs)
Synchronously waits for all futures in the collection.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridWorkerFuture<T>
Future for locally executed closure that defines cancellation logic.
|
Copyright © 2014. All rights reserved.