Package org.apache.ignite.internal.processors.cache.distributed.dht

Class GridDhtGetFuture<K,V>

java.lang.Object

org.apache.ignite.internal.util.future.GridFutureAdapter<R>

org.apache.ignite.internal.util.future.GridCompoundFuture<T,T>

org.apache.ignite.internal.util.future.GridCompoundIdentityFuture<Collection<GridCacheEntryInfo>>

org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtGetFuture<K,V>

All Implemented Interfaces:

Serializable, IgniteInternalFuture<Collection<GridCacheEntryInfo>>, GridDhtFuture<Collection<GridCacheEntryInfo>>, IgniteInClosure<IgniteInternalFuture<Collection<GridCacheEntryInfo>>>

public final class GridDhtGetFuture<K,V>
extends GridCompoundIdentityFuture<Collection<GridCacheEntryInfo>>
implements GridDhtFuture<Collection<GridCacheEntryInfo>>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
GridDhtGetFuture(GridCacheContext<K,V> cctx, long msgId, UUID reader, Map<KeyCacheObject,Boolean> keys, boolean readThrough, @NotNull AffinityTopologyVersion topVer, int taskNameHash, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean recovery, boolean addReaders, @Nullable String txLbl)

Method Summary

Modifier and Type	Method	Description
IgniteUuid	futureId()
Collection<Integer>	invalidPartitions()	Node that future should be able to provide keys to retry before it completes, so it's not necessary to wait till future is done to get retry keys.
boolean	onDone(Collection<GridCacheEntryInfo> res, Throwable err)	Callback to notify that future is finished.
GridCacheVersion	version()

Methods inherited from class org.apache.ignite.internal.util.future.GridCompoundIdentityFuture

toString

Methods inherited from class org.apache.ignite.internal.util.future.GridCompoundFuture

add, apply, cancel, clear, compoundsLockedExclusively, compoundsReadLock, compoundsReadUnlock, future, futures, futuresCountNoLock, hasFutures, hasPending, ignoreFailure, initialized, logDebug, logError, markInitialized, processFailure

Methods inherited from class org.apache.ignite.internal.util.future.GridFutureAdapter

chain, chain, chain, chain, chainCompose, chainCompose, error, get, get, get, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, listen, logger, onCancelled, onDone, onDone, onDone, onDone, reset, result

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.ignite.internal.IgniteInternalFuture

cancel, chain, chain, chain, chain, chainCompose, chainCompose, error, get, get, get, getUninterruptibly, isCancelled, isDone, listen, listen, result

Constructor Detail

GridDhtGetFuture

public GridDhtGetFuture(GridCacheContext<K,V> cctx,
                        long msgId,
                        UUID reader,
                        Map<KeyCacheObject,Boolean> keys,
                        boolean readThrough,
                        @NotNull
                        @NotNull AffinityTopologyVersion topVer,
                        int taskNameHash,
                        @Nullable
                        @Nullable IgniteCacheExpiryPolicy expiryPlc,
                        boolean skipVals,
                        boolean recovery,
                        boolean addReaders,
                        @Nullable
                        @Nullable String txLbl)

Parameters:

cctx - Context.

msgId - Message ID.

reader - Reader.

keys - Keys.

readThrough - Read through flag.

topVer - Topology version.

taskNameHash - Task name hash code.

expiryPlc - Expiry policy.

skipVals - Skip values flag.

txLbl - Transaction label.

Method Detail

invalidPartitions

public Collection<Integer> invalidPartitions()

Node that future should be able to provide keys to retry before it completes, so it's not necessary to wait till future is done to get retry keys.

Specified by:

invalidPartitions in interface GridDhtFuture<K>

Returns:

Keys to retry because this node is no longer a primary or backup.

futureId

public IgniteUuid futureId()

Returns:

Future ID.

version

public GridCacheVersion version()

Returns:

Future version.

onDone

public boolean onDone(Collection<GridCacheEntryInfo> res,
                      Throwable err)

Callback to notify that future is finished. Note that if non-null exception is passed in the result value will be ignored.

Overrides:

onDone in class GridFutureAdapter<Collection<GridCacheEntryInfo>>

Parameters:

res - Optional result.

err - Optional error.

Returns:

True if result was set by this call.