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

Class GridDhtTxEnlistFuture

java.lang.Object

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

org.apache.ignite.internal.processors.cache.GridCacheFutureAdapter<T>

org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxAbstractEnlistFuture<GridCacheReturn>

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

All Implemented Interfaces:

Serializable, AutoCloseable, Iterable<Object>, Iterator<Object>, IgniteInternalFuture<GridCacheReturn>, DhtLockFuture<GridCacheReturn>, GridCacheFuture<GridCacheReturn>, UpdateSourceIterator<Object>, GridSerializableIterator<Object>, GridCloseableIterator<Object>, GridIterator<Object>, IgniteSpiCloseableIterator<Object>

public final class GridDhtTxEnlistFuture
extends GridDhtTxAbstractEnlistFuture<GridCacheReturn>
implements UpdateSourceIterator<Object>

Future processing transaction enlisting and locking of entries produces by cache API operations.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxAbstractEnlistFuture

GridDhtTxAbstractEnlistFuture.LockTimeoutObject

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxAbstractEnlistFuture

cctx, futId, hasNearNodeUpdates, keepBinary, lockVer, log, mvccSnapshot, nearFutId, nearLockVer, nearMiniId, nearNodeId, newDhtNodes, skipNearNodeUpdates, threadId, timeout, timeoutObj, tx

Constructor Summary

Constructors

Constructor and Description
GridDhtTxEnlistFuture(UUID nearNodeId, GridCacheVersion nearLockVer, MvccSnapshot mvccSnapshot, long threadId, IgniteUuid nearFutId, int nearMiniId, GridDhtTxLocalAdapter tx, long timeout, GridCacheContext<?,?> cctx, Collection<Object> rows, EnlistOperation op, @Nullable CacheEntryPredicate filter, boolean needRes, boolean keepBinary) Constructor.

Method Summary

Modifier and Type	Method and Description
protected UpdateSourceIterator<?>	createIterator() Gets source to be updated iterator.
boolean	hasNextX() This method is the same as Iterator.hasNext(), but allows for failure with exception.
boolean	needResult() Gets need previous value flag.
Object	nextX() This method is the same as Iterator.next(), but allows for failure with exception.
protected void	onEntryProcessed(KeyCacheObject key, GridCacheUpdateTxResult txRes) Entry processed callback.
EnlistOperation	operation()
protected @Nullable GridCacheReturn	result0() Gets query result.
String	toString()

Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxAbstractEnlistFuture

clearLockFuture, futureId, init, markNotTrackable, onDone, onError, onNodeLeft, onResult, timeoutException, trackable

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheFutureAdapter

duration, onDone, startTime

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

cancel, chain, chain, error, get, get, get, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, logger, onCancelled, 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.processors.query.UpdateSourceIterator

beforeDetach, close, hasNext, isClosed, iterator, next, remove, removeX

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface java.util.Iterator

forEachRemaining

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

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

Constructor Detail

GridDhtTxEnlistFuture

public GridDhtTxEnlistFuture(UUID nearNodeId,
                             GridCacheVersion nearLockVer,
                             MvccSnapshot mvccSnapshot,
                             long threadId,
                             IgniteUuid nearFutId,
                             int nearMiniId,
                             GridDhtTxLocalAdapter tx,
                             long timeout,
                             GridCacheContext<?,?> cctx,
                             Collection<Object> rows,
                             EnlistOperation op,
                             @Nullable
                             @Nullable CacheEntryPredicate filter,
                             boolean needRes,
                             boolean keepBinary)

Constructor.

Parameters:

nearNodeId - Near node ID.

nearLockVer - Near lock version.

mvccSnapshot - Mvcc snapshot.

threadId - Thread ID.

nearFutId - Near future id.

nearMiniId - Near mini future id.

tx - Transaction.

timeout - Lock acquisition timeout.

cctx - Cache context.

rows - Collection of rows.

op - Operation.

filter - Filter.

needRes - Return previous value flag.

keepBinary - Keep binary flag.

Method Detail

createIterator

protected UpdateSourceIterator<?> createIterator()
                                          throws IgniteCheckedException

Gets source to be updated iterator.

Specified by:

createIterator in class GridDhtTxAbstractEnlistFuture<GridCacheReturn>

Returns:

iterator.

Throws:

IgniteCheckedException - If failed.

result0

@Nullable
protected @Nullable GridCacheReturn result0()

Gets query result.

Specified by:

result0 in class GridDhtTxAbstractEnlistFuture<GridCacheReturn>

Returns:

Query result.

onEntryProcessed

protected void onEntryProcessed(KeyCacheObject key,
                                GridCacheUpdateTxResult txRes)

Entry processed callback.

Specified by:

onEntryProcessed in class GridDhtTxAbstractEnlistFuture<GridCacheReturn>

Parameters:

key - Entry key.

txRes - Update result.

needResult

public boolean needResult()

Gets need previous value flag.

Overrides:

needResult in class GridDhtTxAbstractEnlistFuture<GridCacheReturn>

Returns:

True if previous value is required.

operation

public EnlistOperation operation()

Specified by:

operation in interface UpdateSourceIterator<Object>

Returns:

Operation.

hasNextX

public boolean hasNextX()

This method is the same as Iterator.hasNext(), but allows for failure with exception. Often iterators are used to iterate through values that have not or have partially been received from remote nodes, and need to account for possible network failures, rather than just returning false out of Iterator.hasNext() method.

Specified by:

hasNextX in interface GridIterator<Object>

Returns:

True if iterator contains more elements.

See Also:

Iterator.hasNext()

nextX

public Object nextX()

This method is the same as Iterator.next(), but allows for failure with exception. Often iterators are used to iterate through values that have not or have partially been received from remote nodes, and need to account for possible network failures, rather than throwing NoSuchElementException runtime exception.s

Specified by:

nextX in interface GridIterator<Object>

Returns:

True if iterator contains more elements.

See Also:

Iterator.next()

toString

public String toString()

Overrides:

toString in class GridFutureAdapter<GridCacheReturn>