public final class GridDhtTxQueryResultsEnlistFuture extends GridDhtTxQueryAbstractEnlistFuture implements UpdateSourceIterator<Object>
GridDhtTxAbstractEnlistFuture.LockTimeoutObjectcntcctx, futId, hasNearNodeUpdates, keepBinary, lockVer, log, mvccSnapshot, nearFutId, nearLockVer, nearMiniId, nearNodeId, newDhtNodes, skipNearNodeUpdates, threadId, timeout, timeoutObj, tx| Constructor and Description |
|---|
GridDhtTxQueryResultsEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
Collection<Object> rows,
EnlistOperation op) |
| 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. |
Object |
nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
EnlistOperation |
operation() |
String |
toString() |
onEntryProcessed, result0clearLockFuture, futureId, init, markNotTrackable, needResult, onDone, onError, onNodeLeft, onResult, timeoutException, trackableduration, onDone, startTimecancel, chain, chain, error, get, get, get, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, logger, onCancelled, onDone, onDone, onDone, reset, resultclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitbeforeDetach, close, hasNext, isClosed, iterator, next, remove, removeXforEach, spliteratorforEachRemainingcancel, chain, chain, error, get, get, get, getUninterruptibly, isCancelled, isDone, listen, resultpublic GridDhtTxQueryResultsEnlistFuture(UUID nearNodeId, GridCacheVersion nearLockVer, MvccSnapshot mvccSnapshot, long threadId, IgniteUuid nearFutId, int nearMiniId, GridDhtTxLocalAdapter tx, long timeout, GridCacheContext<?,?> cctx, Collection<Object> rows, EnlistOperation op)
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.protected UpdateSourceIterator<?> createIterator() throws IgniteCheckedException
createIterator in class GridDhtTxAbstractEnlistFuture<Long>IgniteCheckedException - If failed.public EnlistOperation operation()
operation in interface UpdateSourceIterator<Object>public boolean hasNextX()
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.hasNextX in interface GridIterator<Object>True if iterator contains more elements.Iterator.hasNext()public Object nextX()
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.snextX in interface GridIterator<Object>True if iterator contains more elements.Iterator.next()public String toString()
toString in class GridFutureAdapter<Long>
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.1 Release Date : December 9 2020