Uses of Interface
org.apache.ignite.internal.processors.query.UpdateSourceIterator

Packages that use UpdateSourceIterator

Package	Description
org.apache.ignite.internal.processors.cache.distributed.dht
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.query

Uses of UpdateSourceIterator in org.apache.ignite.internal.processors.cache.distributed.dht

Classes in org.apache.ignite.internal.processors.cache.distributed.dht that implement UpdateSourceIterator

Modifier and Type	Class and Description
class	GridDhtTxEnlistFuture Future processing transaction enlisting and locking of entries produces by cache API operations.
class	GridDhtTxQueryResultsEnlistFuture Future processing transaction enlisting and locking of entries produces by complex DML queries with reduce step.

Methods in org.apache.ignite.internal.processors.cache.distributed.dht that return UpdateSourceIterator

Modifier and Type	Method and Description
protected UpdateSourceIterator<?>	GridDhtTxQueryEnlistFuture.createIterator() Gets source to be updated iterator.
protected UpdateSourceIterator<?>	GridDhtTxQueryResultsEnlistFuture.createIterator() Gets source to be updated iterator.
protected abstract UpdateSourceIterator<?>	GridDhtTxAbstractEnlistFuture.createIterator() Gets source to be updated iterator.
protected UpdateSourceIterator<?>	GridDhtTxEnlistFuture.createIterator() Gets source to be updated iterator.

Uses of UpdateSourceIterator in org.apache.ignite.internal.processors.cache.distributed.near

Methods in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type UpdateSourceIterator

Modifier and Type	Method and Description
IgniteInternalFuture<Long>	GridNearTxLocal.updateAsync(GridCacheContext cacheCtx, UpdateSourceIterator<?> it, int pageSize, long timeout, boolean sequential)

Constructors in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type UpdateSourceIterator

Constructor and Description
GridNearTxEnlistFuture(GridCacheContext<?,?> cctx, GridNearTxLocal tx, long timeout, UpdateSourceIterator<?> it, int batchSize, boolean sequential, @Nullable CacheEntryPredicate filter, boolean needRes, boolean keepBinary)
GridNearTxQueryResultsEnlistFuture(GridCacheContext<?,?> cctx, GridNearTxLocal tx, long timeout, UpdateSourceIterator<?> it, int batchSize, boolean sequential)

Uses of UpdateSourceIterator in org.apache.ignite.internal.processors.query

Methods in org.apache.ignite.internal.processors.query that return UpdateSourceIterator

Modifier and Type	Method and Description
UpdateSourceIterator<?>	GridQueryIndexing.executeUpdateOnDataNodeTransactional(GridCacheContext<?,?> cctx, int[] ids, int[] parts, String schema, String qry, Object[] params, int flags, int pageSize, int timeout, AffinityTopologyVersion topVer, MvccSnapshot mvccSnapshot, GridQueryCancel cancel)
UpdateSourceIterator<?>	GridQueryProcessor.executeUpdateOnDataNodeTransactional(GridCacheContext<?,?> cctx, int[] cacheIds, int[] parts, String schema, String qry, Object[] params, int flags, int pageSize, int timeout, AffinityTopologyVersion topVer, MvccSnapshot mvccSnapshot, GridQueryCancel cancel) Execute update on DHT node (i.e. when it is possible to execute and update on all nodes independently).