Uses of Interface
org.apache.ignite.internal.processors.cache.mvcc.MvccSnapshot

Packages that use MvccSnapshot

Package	Description
org.apache.ignite.internal.cache.query.index.sorted.inline
org.apache.ignite.internal.processors.cache	This package contain cache-related processors & persistence implementation.
org.apache.ignite.internal.processors.cache.distributed.dht
org.apache.ignite.internal.processors.cache.distributed.dht.colocated
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.cache.mvcc
org.apache.ignite.internal.processors.cache.mvcc.msg
org.apache.ignite.internal.processors.cache.persistence	This package contain cache with persistence implementation.
org.apache.ignite.internal.processors.cache.query
org.apache.ignite.internal.processors.cache.transactions
org.apache.ignite.internal.processors.cache.tree.mvcc.data
org.apache.ignite.internal.processors.cache.tree.mvcc.search
org.apache.ignite.internal.processors.query

Uses of MvccSnapshot in org.apache.ignite.internal.cache.query.index.sorted.inline

Methods in org.apache.ignite.internal.cache.query.index.sorted.inline that return MvccSnapshot

Modifier and Type	Method and Description
MvccSnapshot	IndexQueryContext.mvccSnapshot()

Constructors in org.apache.ignite.internal.cache.query.index.sorted.inline with parameters of type MvccSnapshot

Constructor and Description
IndexQueryContext(IndexingQueryFilter cacheFilter, BPlusTree.TreeRowClosure<IndexRow,IndexRow> rowFilter, BPlusTree.TreeRowFactory<IndexRow,IndexRow> rowFactory, MvccSnapshot mvccSnapshot)
IndexQueryContext(IndexingQueryFilter cacheFilter, BPlusTree.TreeRowClosure<IndexRow,IndexRow> rowFilter, MvccSnapshot mvccSnapshot)
InlineTreeFilterClosure(IndexingQueryCacheFilter cacheFilter, BPlusTree.TreeRowClosure<IndexRow,IndexRow> rowFilter, MvccSnapshot mvccSnapshot, GridCacheContext<?,?> cctx, IgniteLogger log) Constructor.

Uses of MvccSnapshot in org.apache.ignite.internal.processors.cache

Methods in org.apache.ignite.internal.processors.cache with parameters of type MvccSnapshot

Modifier and Type	Method and Description
<K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>>	IgniteCacheOffheapManagerImpl.cacheEntriesIterator(GridCacheContext cctx, boolean primary, boolean backup, AffinityTopologyVersion topVer, boolean keepBinary, @Nullable MvccSnapshot mvccSnapshot, Boolean dataPageScanEnabled)
<K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>>	IgniteCacheOffheapManager.cacheEntriesIterator(GridCacheContext cctx, boolean primary, boolean backup, AffinityTopologyVersion topVer, boolean keepBinary, @Nullable MvccSnapshot mvccSnapshot, Boolean dataPageScanEnabled)
GridIterator<CacheDataRow>	IgniteCacheOffheapManagerImpl.cacheIterator(int cacheId, boolean primary, boolean backups, AffinityTopologyVersion topVer, @Nullable MvccSnapshot mvccSnapshot, Boolean dataPageScanEnabled)
GridIterator<CacheDataRow>	IgniteCacheOffheapManager.cacheIterator(int cacheId, boolean primary, boolean backup, AffinityTopologyVersion topVer, @Nullable MvccSnapshot mvccSnapshot, Boolean dataPageScanEnabled)
GridIterator<CacheDataRow>	IgniteCacheOffheapManagerImpl.cachePartitionIterator(int cacheId, int part, @Nullable MvccSnapshot mvccSnapshot, Boolean dataPageScanEnabled)
GridIterator<CacheDataRow>	IgniteCacheOffheapManager.cachePartitionIterator(int cacheId, int part, @Nullable MvccSnapshot mvccSnapshot, Boolean dataPageScanEnabled)
GridCursor<? extends CacheDataRow>	IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(int cacheId, KeyCacheObject lower, KeyCacheObject upper, Object x, MvccSnapshot snapshot)
GridCursor<? extends CacheDataRow>	IgniteCacheOffheapManager.CacheDataStore.cursor(int cacheId, KeyCacheObject lower, KeyCacheObject upper, Object x, MvccSnapshot snapshot)
GridCursor<? extends CacheDataRow>	IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(int cacheId, MvccSnapshot mvccSnapshot)
GridCursor<? extends CacheDataRow>	IgniteCacheOffheapManager.CacheDataStore.cursor(int cacheId, MvccSnapshot mvccSnapshot)
GridCursor<? extends CacheDataRow>	IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(MvccSnapshot mvccSnapshot)
GridCursor<? extends CacheDataRow>	IgniteCacheOffheapManager.CacheDataStore.cursor(MvccSnapshot mvccSnapshot)
protected <K1,V1> IgniteInternalFuture<Map<K1,V1>>	GridCacheAdapter.getAllAsync0(@Nullable Collection<KeyCacheObject> keys, @Nullable ReaderArguments readerArgs, boolean readThrough, boolean checkTx, String taskName, boolean deserializeBinary, @Nullable IgniteCacheExpiryPolicy expiry, boolean skipVals, boolean keepCacheObjects, boolean recovery, ReadRepairStrategy readRepairStrategy, boolean needVer, @Nullable String txLbl, MvccSnapshot mvccSnapshot)
protected WALPointer	GridCacheMapEntry.logMvccUpdate(IgniteInternalTx tx, CacheObject val, long expireTime, long updCntr, MvccSnapshot mvccVer)
CacheDataRow	IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccFind(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot snapshot)
CacheDataRow	IgniteCacheOffheapManager.CacheDataStore.mvccFind(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot snapshot)
MvccUpdateResult	IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccLock(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot mvccSnapshot)
MvccUpdateResult	IgniteCacheOffheapManager.CacheDataStore.mvccLock(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot mvccSnapshot)
@Nullable MvccUpdateResult	IgniteCacheOffheapManagerImpl.mvccLock(GridCacheMapEntry entry, MvccSnapshot mvccSnapshot)
@Nullable MvccUpdateResult	IgniteCacheOffheapManager.mvccLock(GridCacheMapEntry entry, MvccSnapshot mvccSnapshot)
GridCacheUpdateTxResult	GridCacheEntryEx.mvccLock(GridDhtTxLocalAdapter tx, MvccSnapshot mvccVer)
GridCacheUpdateTxResult	GridCacheMapEntry.mvccLock(GridDhtTxLocalAdapter tx, MvccSnapshot mvccVer)
@Nullable CacheDataRow	IgniteCacheOffheapManagerImpl.mvccRead(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot mvccSnapshot)
@Nullable CacheDataRow	IgniteCacheOffheapManager.mvccRead(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot mvccSnapshot)
MvccUpdateResult	IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccRemove(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot mvccSnapshot, @Nullable CacheEntryPredicate filter, boolean primary, boolean needHistory, boolean needOldVal, boolean retVal)
MvccUpdateResult	IgniteCacheOffheapManager.CacheDataStore.mvccRemove(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot mvccSnapshot, @Nullable CacheEntryPredicate filter, boolean primary, boolean needHistory, boolean needOldVal, boolean retVal)
MvccUpdateResult	IgniteCacheOffheapManagerImpl.mvccRemove(GridCacheMapEntry entry, MvccSnapshot mvccSnapshot, boolean primary, boolean needHistory, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal)
@Nullable MvccUpdateResult	IgniteCacheOffheapManager.mvccRemove(GridCacheMapEntry entry, MvccSnapshot mvccSnapshot, boolean primary, boolean needHist, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal)
GridCacheUpdateTxResult	GridCacheEntryEx.mvccRemove(@Nullable IgniteInternalTx tx, UUID affNodeId, AffinityTopologyVersion topVer, MvccSnapshot mvccVer, boolean needHist, boolean needOldValue, @Nullable CacheEntryPredicate filter, boolean retVal)
GridCacheUpdateTxResult	GridCacheMapEntry.mvccRemove(IgniteInternalTx tx, UUID affNodeId, AffinityTopologyVersion topVer, MvccSnapshot mvccVer, boolean needHistory, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal)
GridCacheUpdateTxResult	GridCacheEntryEx.mvccSet(@Nullable IgniteInternalTx tx, UUID affNodeId, CacheObject val, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs, long ttl0, AffinityTopologyVersion topVer, MvccSnapshot mvccVer, GridCacheOperation op, boolean needHistory, boolean noCreate, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal, boolean keepBinary)
GridCacheUpdateTxResult	GridCacheMapEntry.mvccSet(IgniteInternalTx tx, UUID affNodeId, CacheObject val, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs, long ttl0, AffinityTopologyVersion topVer, MvccSnapshot mvccVer, GridCacheOperation op, boolean needHistory, boolean noCreate, boolean needOldVal, CacheEntryPredicate filter, boolean retVal, boolean keepBinary)
MvccUpdateResult	IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdate(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, MvccSnapshot mvccSnapshot, @Nullable CacheEntryPredicate filter, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs, boolean primary, boolean needHistory, boolean noCreate, boolean needOldVal, boolean retVal, boolean keepBinary)
MvccUpdateResult	IgniteCacheOffheapManager.CacheDataStore.mvccUpdate(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, MvccSnapshot mvccSnapshot, @Nullable CacheEntryPredicate filter, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs, boolean primary, boolean needHist, boolean noCreate, boolean needOldVal, boolean retVal, boolean keepBinary)
MvccUpdateResult	IgniteCacheOffheapManagerImpl.mvccUpdate(GridCacheMapEntry entry, CacheObject val, GridCacheVersion ver, long expireTime, MvccSnapshot mvccSnapshot, boolean primary, boolean needHistory, boolean noCreate, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal, boolean keepBinary, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs)
MvccUpdateResult	IgniteCacheOffheapManager.mvccUpdate(GridCacheMapEntry entry, CacheObject val, GridCacheVersion ver, long expireTime, MvccSnapshot mvccSnapshot, boolean primary, boolean needHist, boolean noCreate, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal, boolean keepBinary, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs)
GridCacheUpdateTxResult	GridCacheEntryEx.mvccUpdateRowsWithPreloadInfo(IgniteInternalTx tx, UUID affNodeId, AffinityTopologyVersion topVer, List<GridCacheEntryInfo> entries, GridCacheOperation op, MvccSnapshot mvccVer, IgniteUuid futId, int batchNum)
GridCacheUpdateTxResult	GridCacheMapEntry.mvccUpdateRowsWithPreloadInfo(IgniteInternalTx tx, UUID affNodeId, AffinityTopologyVersion topVer, List<GridCacheEntryInfo> entries, GridCacheOperation op, MvccSnapshot mvccVer, IgniteUuid futId, int batchNum)

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

Fields in org.apache.ignite.internal.processors.cache.distributed.dht declared as MvccSnapshot

Modifier and Type	Field and Description
protected MvccSnapshot	GridPartitionedSingleGetFuture.mvccSnapshot
protected MvccSnapshot	GridPartitionedGetFuture.mvccSnapshot
protected MvccSnapshot	GridDhtTxAbstractEnlistFuture.mvccSnapshot

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

Modifier and Type	Method and Description
MvccSnapshot	GridDhtTxQueryFirstEnlistRequest.mvccSnapshot()
MvccSnapshot	GridDhtTxPrepareRequest.mvccSnapshot()
MvccSnapshot	GridDhtTxFinishRequest.mvccSnapshot()

Methods in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type MvccSnapshot

Modifier and Type	Method and Description
GridDhtFuture<Collection<GridCacheEntryInfo>>	GridDhtCacheAdapter.getDhtAsync(UUID reader, long msgId, Map<KeyCacheObject,Boolean> keys, boolean addReaders, boolean readThrough, AffinityTopologyVersion topVer, int taskNameHash, @Nullable IgniteCacheExpiryPolicy expiry, boolean skipVals, boolean recovery, @Nullable String txLbl, MvccSnapshot mvccSnapshot)
GridDhtTxLocal	GridDhtTransactionalCacheAdapter.initTxTopologyVersion(UUID nodeId, ClusterNode nearNode, GridCacheVersion nearLockVer, IgniteUuid nearFutId, int nearMiniId, boolean firstClientReq, AffinityTopologyVersion topVer, long nearThreadId, long timeout, int txTaskNameHash, MvccSnapshot snapshot)

Constructors in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type MvccSnapshot

Constructor and 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, MvccSnapshot mvccSnapshot)
GridDhtGetSingleFuture(GridCacheContext<K,V> cctx, long msgId, UUID reader, KeyCacheObject key, boolean addRdr, boolean readThrough, @NotNull AffinityTopologyVersion topVer, int taskNameHash, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean recovery, @Nullable String txLbl, @Nullable MvccSnapshot mvccSnapshot)
GridDhtTxAbstractEnlistFuture(UUID nearNodeId, GridCacheVersion nearLockVer, MvccSnapshot mvccSnapshot, long threadId, IgniteUuid nearFutId, int nearMiniId, GridDhtTxLocalAdapter tx, long timeout, GridCacheContext<?,?> cctx, @Nullable CacheEntryPredicate filter, boolean keepBinary)
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.
GridDhtTxFinishRequest(UUID nearNodeId, IgniteUuid futId, int miniId, @NotNull AffinityTopologyVersion topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, long threadId, TransactionIsolation isolation, boolean commit, boolean invalidate, boolean sys, byte plc, boolean sysInvalidate, CacheWriteSynchronizationMode syncMode, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, Collection<GridCacheVersion> pendingVers, int txSize, int taskNameHash, boolean addDepInfo, boolean retVal, boolean waitRemoteTxs, MvccSnapshot mvccSnapshot, Collection<PartitionUpdateCountersMessage> updCntrs)
GridDhtTxFinishRequest(UUID nearNodeId, IgniteUuid futId, int miniId, @NotNull AffinityTopologyVersion topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, long threadId, TransactionIsolation isolation, boolean commit, boolean invalidate, boolean sys, byte plc, boolean sysInvalidate, CacheWriteSynchronizationMode syncMode, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, Collection<GridCacheVersion> pendingVers, int txSize, int taskNameHash, boolean addDepInfo, Collection<Long> updateIdxs, boolean retVal, boolean waitRemoteTxs, MvccSnapshot mvccSnapshot, Collection<PartitionUpdateCountersMessage> updCntrs)
GridDhtTxPrepareRequest(IgniteUuid futId, int miniId, AffinityTopologyVersion topVer, GridDhtTxLocalAdapter tx, long timeout, Collection<IgniteTxEntry> dhtWrites, Collection<IgniteTxEntry> nearWrites, Map<UUID,Collection<UUID>> txNodes, GridCacheVersion nearXidVer, boolean last, boolean onePhaseCommit, int taskNameHash, boolean addDepInfo, boolean storeWriteThrough, boolean retVal, MvccSnapshot mvccSnapshot, Collection<PartitionUpdateCountersMessage> updCntrs)
GridDhtTxQueryAbstractEnlistFuture(UUID nearNodeId, GridCacheVersion nearLockVer, MvccSnapshot mvccSnapshot, long threadId, IgniteUuid nearFutId, int nearMiniId, GridDhtTxLocalAdapter tx, long timeout, GridCacheContext<?,?> cctx) Constructor.
GridDhtTxQueryEnlistFuture(UUID nearNodeId, GridCacheVersion nearLockVer, MvccSnapshot mvccSnapshot, long threadId, IgniteUuid nearFutId, int nearMiniId, GridDhtTxLocalAdapter tx, int[] cacheIds, int[] parts, String schema, String qry, Object[] params, int flags, int pageSize, long timeout, GridCacheContext<?,?> cctx)
GridDhtTxQueryResultsEnlistFuture(UUID nearNodeId, GridCacheVersion nearLockVer, MvccSnapshot mvccSnapshot, long threadId, IgniteUuid nearFutId, int nearMiniId, GridDhtTxLocalAdapter tx, long timeout, GridCacheContext<?,?> cctx, Collection<Object> rows, EnlistOperation op)
GridPartitionedGetFuture(GridCacheContext<K,V> cctx, Collection<KeyCacheObject> keys, boolean readThrough, boolean forcePrimary, String taskName, boolean deserializeBinary, boolean recovery, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObjects, @Nullable String txLbl, @Nullable MvccSnapshot mvccSnapshot, ClusterNode affNode)
GridPartitionedSingleGetFuture(GridCacheContext cctx, KeyCacheObject key, AffinityTopologyVersion topVer, boolean readThrough, boolean forcePrimary, String taskName, boolean deserializeBinary, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObjects, boolean recovery, String txLbl, @Nullable MvccSnapshot mvccSnapshot)

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

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.colocated with parameters of type MvccSnapshot

Modifier and Type	Method and Description
IgniteInternalFuture<Map<K,V>>	GridDhtColocatedCache.loadAsync(@Nullable Collection<KeyCacheObject> keys, boolean readThrough, boolean forcePrimary, AffinityTopologyVersion topVer, String taskName, boolean deserializeBinary, boolean recovery, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObj, @Nullable String txLbl, @Nullable MvccSnapshot mvccSnapshot)
IgniteInternalFuture<Object>	GridDhtColocatedCache.loadAsync(KeyCacheObject key, boolean readThrough, boolean forcePrimary, AffinityTopologyVersion topVer, String taskName, boolean deserializeBinary, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObj, boolean recovery, @Nullable MvccSnapshot mvccSnapshot, @Nullable String txLbl)

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

Fields in org.apache.ignite.internal.processors.cache.distributed.near declared as MvccSnapshot

Modifier and Type	Field and Description
protected MvccSnapshot	GridNearTxAbstractEnlistFuture.mvccSnapshot MVCC snapshot.

Methods in org.apache.ignite.internal.processors.cache.distributed.near that return MvccSnapshot

Modifier and Type	Method and Description
@Nullable MvccSnapshot	GridNearTxFinishRequest.mvccSnapshot()
MvccSnapshot	GridNearTxEnlistRequest.mvccSnapshot()
MvccSnapshot	GridNearTxQueryEnlistRequest.mvccSnapshot()
@Nullable MvccSnapshot	GridNearSingleGetRequest.mvccSnapshot()
@Nullable MvccSnapshot	GridNearGetRequest.mvccSnapshot()
MvccSnapshot	GridNearTxQueryResultsEnlistRequest.mvccSnapshot()

Methods in org.apache.ignite.internal.processors.cache.distributed.near that return types with arguments of type MvccSnapshot

Modifier and Type	Method and Description
IgniteInternalFuture<MvccSnapshot>	GridNearTxLocal.requestSnapshot() Requests version on coordinator.

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

Modifier and Type	Method and Description
void	GridNearTxLocal.mvccSnapshot(MvccSnapshot mvccSnapshot)

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

Constructor and Description
GridNearGetRequest(int cacheId, IgniteUuid futId, IgniteUuid miniId, GridCacheVersion ver, Map<KeyCacheObject,Boolean> keys, boolean readThrough, @NotNull AffinityTopologyVersion topVer, int taskNameHash, long createTtl, long accessTtl, boolean addReader, boolean skipVals, boolean addDepInfo, boolean recovery, @Nullable String txLbl, @Nullable MvccSnapshot mvccSnapshot)
GridNearSingleGetRequest(int cacheId, long futId, KeyCacheObject key, boolean readThrough, @NotNull AffinityTopologyVersion topVer, int taskNameHash, long createTtl, long accessTtl, boolean skipVals, boolean addReader, boolean needVer, boolean addDepInfo, boolean recovery, @Nullable String txLbl, MvccSnapshot mvccSnapshot)
GridNearTxFinishRequest(IgniteUuid futId, GridCacheVersion xidVer, long threadId, boolean commit, boolean invalidate, boolean sys, byte plc, CacheWriteSynchronizationMode syncMode, boolean explicitLock, boolean storeEnabled, @NotNull AffinityTopologyVersion topVer, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, int txSize, int taskNameHash, MvccSnapshot mvccSnapshot, boolean addDepInfo)
GridNearTxQueryEnlistRequest(int cacheId, long threadId, IgniteUuid futId, int miniId, AffinityTopologyVersion topVer, GridCacheVersion lockVer, MvccSnapshot mvccSnapshot, int[] cacheIds, int[] parts, String schema, String qry, Object[] params, int flags, int pageSize, long timeout, long txTimeout, int taskNameHash, boolean clientFirst)

Uses of MvccSnapshot in org.apache.ignite.internal.processors.cache.mvcc

Classes in org.apache.ignite.internal.processors.cache.mvcc that implement MvccSnapshot

Modifier and Type	Class and Description
class	MvccSnapshotWithoutTxs

Fields in org.apache.ignite.internal.processors.cache.mvcc declared as MvccSnapshot

Modifier and Type	Field and Description
static MvccSnapshot	MvccUtils.MVCC_MAX_SNAPSHOT A special snapshot for which all committed versions are visible

Methods in org.apache.ignite.internal.processors.cache.mvcc that return MvccSnapshot

Modifier and Type	Method and Description
MvccSnapshot	MvccProcessorImpl.requestReadSnapshotLocal()
MvccSnapshot	MvccProcessor.requestReadSnapshotLocal()
static MvccSnapshot	MvccUtils.requestSnapshot(@NotNull GridNearTxLocal tx)
MvccSnapshot	MvccProcessorImpl.requestWriteSnapshotLocal()
MvccSnapshot	MvccProcessor.requestWriteSnapshotLocal()
MvccSnapshot	VacuumTask.snapshot()
MvccSnapshot	MvccQueryTracker.snapshot()
MvccSnapshot	MvccQueryTrackerImpl.snapshot()
MvccSnapshot	StaticMvccQueryTracker.snapshot()
MvccSnapshot	MvccSnapshot.withoutActiveTransactions()
MvccSnapshot	MvccSnapshotWithoutTxs.withoutActiveTransactions()

Methods in org.apache.ignite.internal.processors.cache.mvcc that return types with arguments of type MvccSnapshot

Modifier and Type	Method and Description
IgniteInternalFuture<MvccSnapshot>	MvccProcessorImpl.requestReadSnapshotAsync() Requests snapshot on Mvcc coordinator.
IgniteInternalFuture<MvccSnapshot>	MvccProcessor.requestReadSnapshotAsync() Requests snapshot on Mvcc coordinator.
IgniteInternalFuture<MvccSnapshot>	MvccQueryTracker.requestSnapshot() Requests version on coordinator.
IgniteInternalFuture<MvccSnapshot>	MvccQueryTrackerImpl.requestSnapshot() Requests version on coordinator.
IgniteInternalFuture<MvccSnapshot>	StaticMvccQueryTracker.requestSnapshot() Requests version on coordinator.
IgniteInternalFuture<MvccSnapshot>	MvccProcessorImpl.requestWriteSnapshotAsync() Requests snapshot on Mvcc coordinator.
IgniteInternalFuture<MvccSnapshot>	MvccProcessor.requestWriteSnapshotAsync() Requests snapshot on Mvcc coordinator.

Methods in org.apache.ignite.internal.processors.cache.mvcc with parameters of type MvccSnapshot

Modifier and Type	Method and Description
void	MvccProcessorImpl.ackQueryDone(MvccSnapshot snapshot, long qryId)
void	MvccProcessor.ackQueryDone(MvccSnapshot snapshot, long qryId)
IgniteInternalFuture<Void>	MvccProcessorImpl.ackTxCommit(MvccSnapshot updateVer)
IgniteInternalFuture<Void>	MvccProcessor.ackTxCommit(MvccSnapshot updateVer)
static int	MvccUtils.getVisibleState(GridCacheContext cctx, long link, MvccSnapshot snapshot) Checks if a row's new version is visible for the given snapshot.
static boolean	MvccUtils.isActive(GridCacheContext cctx, long mvccCrd, long mvccCntr, MvccSnapshot snapshot)
static boolean	MvccUtils.isVisible(GridCacheContext cctx, MvccSnapshot snapshot, DataPageIO dataIo, long pageAddr, int itemId, int pageSize)
static boolean	MvccUtils.isVisible(GridCacheContext cctx, MvccSnapshot snapshot, long mvccCrd, long mvccCntr, int opCntr) Checks if version is visible from the given snapshot.
static boolean	MvccUtils.isVisible(GridCacheContext cctx, MvccSnapshot snapshot, long mvccCrd, long mvccCntr, int opCntrWithHints, boolean useTxLog) Checks if version is visible from the given snapshot.
static boolean	MvccUtils.isVisible(GridCacheContext cctx, MvccSnapshot snapshot, long crd, long cntr, int opCntr, long link) Checks visibility of the given row versions from the given snapshot.
void	MvccSnapshotFuture.onResponse(MvccSnapshot res)
void	MvccSnapshotResponseListener.onResponse(MvccSnapshot res)
static IgniteTxUnexpectedStateCheckedException	MvccUtils.unexpectedStateException(GridCacheContext cctx, byte state, long crd, long cntr, int opCntr, MvccSnapshot snapshot)

Constructors in org.apache.ignite.internal.processors.cache.mvcc with parameters of type MvccSnapshot

Constructor and Description
StaticMvccQueryTracker(GridCacheContext cctx, MvccSnapshot snapshot)

Uses of MvccSnapshot in org.apache.ignite.internal.processors.cache.mvcc.msg

Classes in org.apache.ignite.internal.processors.cache.mvcc.msg that implement MvccSnapshot

Modifier and Type	Class and Description
class	MvccSnapshotResponse

Methods in org.apache.ignite.internal.processors.cache.mvcc.msg that return MvccSnapshot

Modifier and Type	Method and Description
MvccSnapshot	MvccSnapshotResponse.withoutActiveTransactions()

Uses of MvccSnapshot in org.apache.ignite.internal.processors.cache.persistence

Methods in org.apache.ignite.internal.processors.cache.persistence with parameters of type MvccSnapshot

Modifier and Type	Method and Description
GridCursor<? extends CacheDataRow>	GridCacheOffheapManager.GridCacheDataStore.cursor(int cacheId, KeyCacheObject lower, KeyCacheObject upper, Object x, MvccSnapshot mvccSnapshot)
GridCursor<? extends CacheDataRow>	GridCacheOffheapManager.GridCacheDataStore.cursor(int cacheId, MvccSnapshot mvccSnapshot)
GridCursor<? extends CacheDataRow>	GridCacheOffheapManager.GridCacheDataStore.cursor(MvccSnapshot mvccSnapshot)
CacheDataRow	GridCacheOffheapManager.GridCacheDataStore.mvccFind(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot snapshot)
MvccUpdateResult	GridCacheOffheapManager.GridCacheDataStore.mvccLock(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot mvccSnapshot)
MvccUpdateResult	GridCacheOffheapManager.GridCacheDataStore.mvccRemove(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot mvccVer, CacheEntryPredicate filter, boolean primary, boolean needHistory, boolean needOldVal, boolean retVal)
MvccUpdateResult	GridCacheOffheapManager.GridCacheDataStore.mvccUpdate(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, MvccSnapshot mvccVer, CacheEntryPredicate filter, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs, boolean primary, boolean needHistory, boolean noCreate, boolean needOldVal, boolean retVal, boolean keepBinary)

Uses of MvccSnapshot in org.apache.ignite.internal.processors.cache.query

Constructors in org.apache.ignite.internal.processors.cache.query with parameters of type MvccSnapshot

Constructor and Description

GridCacheQueryAdapter(GridCacheContext<?,?> cctx, GridCacheQueryType type, IgniteLogger log, int pageSize, long timeout, boolean incBackups, boolean dedup, ClusterGroup prj, IgniteBiPredicate<Object,Object> filter, @Nullable Integer part, @Nullable String clsName, String clause, IndexQueryDesc idxQryDesc, int limit, boolean incMeta, boolean keepBinary, int taskHash, MvccSnapshot mvccSnapshot, Boolean dataPageScanEnabled) Cache query adapter for local query processing.

Uses of MvccSnapshot in org.apache.ignite.internal.processors.cache.transactions

Fields in org.apache.ignite.internal.processors.cache.transactions declared as MvccSnapshot

Modifier and Type	Field and Description
protected MvccSnapshot	IgniteTxAdapter.mvccSnapshot Mvcc tx update snapshot.

Methods in org.apache.ignite.internal.processors.cache.transactions that return MvccSnapshot

Modifier and Type	Method and Description
@Nullable MvccSnapshot	IgniteTxAdapter.mvccSnapshot()
MvccSnapshot	IgniteInternalTx.mvccSnapshot()

Methods in org.apache.ignite.internal.processors.cache.transactions with parameters of type MvccSnapshot

Modifier and Type	Method and Description
void	IgniteTxHandler.mvccEnlistBatch(GridDhtTxRemote tx, GridCacheContext ctx, EnlistOperation op, List<KeyCacheObject> keys, List<Message> vals, MvccSnapshot snapshot, IgniteUuid futId, int batchNum) Writes updated values on the backup node.
void	IgniteTxAdapter.mvccSnapshot(MvccSnapshot mvccSnapshot)
void	IgniteInternalTx.mvccSnapshot(MvccSnapshot mvccSnapshot)

Uses of MvccSnapshot in org.apache.ignite.internal.processors.cache.tree.mvcc.data

Constructors in org.apache.ignite.internal.processors.cache.tree.mvcc.data with parameters of type MvccSnapshot

Constructor and Description
MvccUpdateDataRow(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, int part, long expireTime, MvccSnapshot mvccSnapshot, MvccVersion newVer, @Nullable CacheEntryPredicate filter, boolean primary, boolean lockOnly, boolean needHist, boolean fastUpdate, boolean needOldVal, boolean needPrevValue)

Uses of MvccSnapshot in org.apache.ignite.internal.processors.cache.tree.mvcc.search

Constructors in org.apache.ignite.internal.processors.cache.tree.mvcc.search with parameters of type MvccSnapshot

Constructor and Description
MvccSnapshotSearchRow(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot snapshot) Constructor.

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

Methods in org.apache.ignite.internal.processors.query with parameters of type MvccSnapshot

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).