| Modifier and Type | Method and Description |
|---|---|
GridIterator<CacheDataRow> |
IgniteCacheOffheapManager.cacheIterator(int cacheId,
boolean primary,
boolean backup,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot) |
GridIterator<CacheDataRow> |
IgniteCacheOffheapManagerImpl.cacheIterator(int cacheId,
boolean primary,
boolean backups,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot) |
GridIterator<CacheDataRow> |
IgniteCacheOffheapManager.cachePartitionIterator(int cacheId,
int part,
MvccSnapshot mvccSnapshot) |
GridIterator<CacheDataRow> |
IgniteCacheOffheapManagerImpl.cachePartitionIterator(int cacheId,
int part,
MvccSnapshot mvccSnapshot) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x,
MvccSnapshot snapshot) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x,
MvccSnapshot snapshot) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(int cacheId,
MvccSnapshot mvccSnapshot) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(int cacheId,
MvccSnapshot mvccSnapshot) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(MvccSnapshot mvccSnapshot) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(MvccSnapshot mvccSnapshot) |
protected <K1,V1> IgniteInternalFuture<Map<K1,V1>> |
GridCacheAdapter.getAllAsync0(Collection<KeyCacheObject> keys,
ReaderArguments readerArgs,
boolean readThrough,
boolean checkTx,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiry,
boolean skipVals,
boolean keepCacheObjects,
boolean recovery,
boolean needVer,
MvccSnapshot mvccSnapshot) |
CacheObject |
GridCacheEntryEx.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
MvccSnapshot mvccVer) |
CacheObject |
GridCacheMapEntry.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expirePlc,
boolean keepBinary,
MvccSnapshot mvccVer) |
EntryGetResult |
GridCacheEntryEx.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
UUID subjId,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
MvccSnapshot mvccVer,
ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
UUID subjId,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
MvccSnapshot mvccVer,
ReaderArguments readerArgs) |
EntryGetResult |
GridCacheEntryEx.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
MvccSnapshot mvccVer,
ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
MvccSnapshot mvccVer,
ReaderArguments readerArgs) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerRemove(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr,
MvccSnapshot mvccVer) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerRemove(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr,
MvccSnapshot mvccVer) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr,
MvccSnapshot mvccVer) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr,
MvccSnapshot mvccVer) |
protected WALPointer |
GridCacheMapEntry.logMvccUpdate(IgniteInternalTx tx,
CacheObject val,
long expireTime,
long updCntr,
MvccSnapshot mvccVer) |
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.mvccFind(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccFind(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccLock(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccLock(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
MvccUpdateResult |
IgniteCacheOffheapManager.mvccLock(GridCacheMapEntry entry,
MvccSnapshot mvccSnapshot) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.mvccLock(GridCacheMapEntry entry,
MvccSnapshot mvccSnapshot) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccLock(GridDhtTxLocalAdapter tx,
MvccSnapshot mvccVer) |
GridCacheUpdateTxResult |
GridCacheMapEntry.mvccLock(GridDhtTxLocalAdapter tx,
MvccSnapshot mvccVer) |
CacheDataRow |
IgniteCacheOffheapManager.mvccRead(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot ver) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.mvccRead(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot ver) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccRemove(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot,
CacheEntryPredicate filter,
boolean primary,
boolean needHistory,
boolean needOldVal,
boolean retVal) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccRemove(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot,
CacheEntryPredicate filter,
boolean primary,
boolean needHistory,
boolean needOldVal,
boolean retVal) |
MvccUpdateResult |
IgniteCacheOffheapManager.mvccRemove(GridCacheMapEntry entry,
MvccSnapshot mvccSnapshot,
boolean primary,
boolean needHist,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.mvccRemove(GridCacheMapEntry entry,
MvccSnapshot mvccSnapshot,
boolean primary,
boolean needHistory,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccRemove(IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
boolean needHist,
boolean needOldValue,
CacheEntryPredicate filter,
boolean retVal) |
GridCacheUpdateTxResult |
GridCacheMapEntry.mvccRemove(IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
boolean needHistory,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal) |
GridLongList |
IgniteCacheOffheapManager.mvccRemoveNative(boolean primary,
GridCacheMapEntry entry,
MvccSnapshot mvccSnapshot) |
GridLongList |
IgniteCacheOffheapManagerImpl.mvccRemoveNative(boolean primary,
GridCacheMapEntry entry,
MvccSnapshot mvccSnapshot) |
GridLongList |
IgniteCacheOffheapManager.CacheDataStore.mvccRemoveNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
GridLongList |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccRemoveNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccSet(IgniteInternalTx tx,
UUID affNodeId,
CacheObject val,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
long ttl0,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
GridCacheOperation op,
boolean needHist,
boolean noCreate,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal) |
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) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHist,
boolean noCreate,
boolean needOldVal,
boolean retVal) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
boolean retVal) |
MvccUpdateResult |
IgniteCacheOffheapManager.mvccUpdate(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
boolean primary,
boolean needHist,
boolean noCreate,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.mvccUpdate(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs) |
GridLongList |
IgniteCacheOffheapManager.mvccUpdateNative(boolean primary,
GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot) |
GridLongList |
IgniteCacheOffheapManagerImpl.mvccUpdateNative(boolean primary,
GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot) |
GridLongList |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdateNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot) |
GridLongList |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdateNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot) |
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) |
| Modifier and Type | Field and Description |
|---|---|
protected MvccSnapshot |
GridPartitionedGetFuture.mvccSnapshot |
protected MvccSnapshot |
GridDhtTxAbstractEnlistFuture.mvccSnapshot |
protected MvccSnapshot |
GridPartitionedSingleGetFuture.mvccSnapshot |
| Modifier and Type | Method and Description |
|---|---|
MvccSnapshot |
GridDhtTxQueryFirstEnlistRequest.mvccSnapshot() |
MvccSnapshot |
GridDhtTxFinishRequest.mvccSnapshot() |
MvccSnapshot |
GridDhtTxPrepareRequest.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,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiry,
boolean skipVals,
boolean recovery,
MvccSnapshot mvccSnapshot) |
void |
GridPartitionedGetFuture.onResponse(MvccSnapshot res) |
| Constructor and Description |
|---|
GridDhtGetFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean recovery,
boolean addReaders,
MvccSnapshot mvccSnapshot) |
GridDhtGetSingleFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
KeyCacheObject key,
boolean addRdr,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean recovery,
MvccSnapshot mvccSnapshot) |
GridDhtTxAbstractEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
int[] parts,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
CacheEntryPredicate filter) |
GridDhtTxEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
Collection<Object> rows,
EnlistOperation op,
CacheEntryPredicate filter,
boolean needRes)
Constructor.
|
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
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,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean retVal,
boolean waitRemoteTxs,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
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,
UUID subjId,
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,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean storeWriteThrough,
boolean retVal,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> counters) |
GridDhtTxQueryAbstractEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
int[] parts,
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,
UUID subjId,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
MvccSnapshot mvccSnapshot) |
GridPartitionedSingleGetFuture(GridCacheContext cctx,
KeyCacheObject key,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
boolean recovery,
MvccSnapshot mvccSnapshot) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridDhtColocatedCache.loadAsync(Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
AffinityTopologyVersion topVer,
UUID subjId,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObj,
MvccSnapshot mvccSnapshot) |
IgniteInternalFuture<Object> |
GridDhtColocatedCache.loadAsync(KeyCacheObject key,
boolean readThrough,
boolean forcePrimary,
AffinityTopologyVersion topVer,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObj,
boolean recovery,
MvccSnapshot mvccSnapshot) |
| Modifier and Type | Field and Description |
|---|---|
protected MvccSnapshot |
GridNearTxAbstractEnlistFuture.mvccSnapshot
MVCC snapshot.
|
| Modifier and Type | Method and Description |
|---|---|
MvccSnapshot |
GridNearTxQueryResultsEnlistRequest.mvccSnapshot() |
MvccSnapshot |
GridNearTxEnlistRequest.mvccSnapshot() |
MvccSnapshot |
GridNearTxPrepareResponse.mvccSnapshot() |
MvccSnapshot |
GridNearTxQueryEnlistRequest.mvccSnapshot() |
MvccSnapshot |
GridNearGetRequest.mvccSnapshot() |
MvccSnapshot |
GridNearSingleGetRequest.mvccSnapshot() |
MvccSnapshot |
GridNearTxFinishRequest.mvccSnapshot() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearTxPrepareResponse.mvccSnapshot(MvccSnapshot mvccSnapshot) |
| Constructor and Description |
|---|
GridNearGetRequest(int cacheId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion ver,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean addReader,
boolean skipVals,
boolean addDepInfo,
boolean recovery,
MvccSnapshot mvccSnapshot) |
GridNearSingleGetRequest(int cacheId,
long futId,
KeyCacheObject key,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean skipVals,
boolean addReader,
boolean needVer,
boolean addDepInfo,
boolean recovery,
MvccSnapshot mvccSnapshot) |
GridNearTxFinishRequest(IgniteUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
boolean explicitLock,
boolean storeEnabled,
AffinityTopologyVersion topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
UUID subjId,
int taskNameHash,
MvccSnapshot mvccSnapshot,
boolean addDepInfo) |
GridNearTxQueryEnlistRequest(int cacheId,
long threadId,
IgniteUuid futId,
int miniId,
UUID subjId,
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) |
| Modifier and Type | Class and Description |
|---|---|
class |
MvccSnapshotWithoutTxs |
| Modifier and Type | Method and Description |
|---|---|
static MvccSnapshot |
MvccUtils.requestSnapshot(GridCacheContext cctx,
GridNearTxLocal tx) |
MvccSnapshot |
MvccQueryTracker.snapshot() |
MvccSnapshot |
VacuumTask.snapshot() |
MvccSnapshot |
StaticMvccQueryTracker.snapshot() |
MvccSnapshot |
MvccQueryTrackerImpl.snapshot() |
MvccSnapshot |
MvccProcessorImpl.tryRequestSnapshotLocal() |
MvccSnapshot |
MvccProcessor.tryRequestSnapshotLocal() |
MvccSnapshot |
MvccProcessorImpl.tryRequestSnapshotLocal(IgniteInternalTx tx) |
MvccSnapshot |
MvccProcessor.tryRequestSnapshotLocal(IgniteInternalTx tx) |
MvccSnapshot |
MvccSnapshot.withoutActiveTransactions() |
MvccSnapshot |
MvccSnapshotWithoutTxs.withoutActiveTransactions() |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<MvccSnapshot> |
MvccQueryTracker.requestSnapshot()
Requests version on coordinator.
|
IgniteInternalFuture<MvccSnapshot> |
StaticMvccQueryTracker.requestSnapshot()
Requests version on coordinator.
|
IgniteInternalFuture<MvccSnapshot> |
MvccQueryTrackerImpl.requestSnapshot()
Requests version on coordinator.
|
IgniteInternalFuture<MvccSnapshot> |
MvccQueryTracker.requestSnapshot(AffinityTopologyVersion topVer)
Requests version on coordinator.
|
IgniteInternalFuture<MvccSnapshot> |
StaticMvccQueryTracker.requestSnapshot(AffinityTopologyVersion topVer)
Requests version on coordinator.
|
IgniteInternalFuture<MvccSnapshot> |
MvccQueryTrackerImpl.requestSnapshot(AffinityTopologyVersion topVer)
Requests version on coordinator.
|
IgniteInternalFuture<MvccSnapshot> |
MvccProcessorImpl.requestSnapshotAsync(IgniteInternalTx tx)
Requests snapshot on Mvcc coordinator.
|
IgniteInternalFuture<MvccSnapshot> |
MvccProcessor.requestSnapshotAsync(IgniteInternalTx tx)
Requests snapshot on Mvcc coordinator.
|
| 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) |
IgniteInternalFuture<Void> |
MvccProcessorImpl.ackTxCommit(MvccVersion updateVer,
MvccSnapshot readSnapshot,
long qryId) |
IgniteInternalFuture<Void> |
MvccProcessor.ackTxCommit(MvccVersion updateVer,
MvccSnapshot readSnapshot,
long qryId) |
void |
MvccProcessorImpl.ackTxRollback(MvccVersion updateVer,
MvccSnapshot readSnapshot,
long qryTrackerId) |
void |
MvccProcessor.ackTxRollback(MvccVersion updateVer,
MvccSnapshot readSnapshot,
long qryTrackerId) |
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,
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 opCntr,
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 |
MvccSnapshotResponseListener.onResponse(MvccSnapshot res) |
void |
MvccSnapshotFuture.onResponse(MvccSnapshot res) |
static IgniteTxMvccVersionCheckedException |
MvccUtils.unexpectedStateException(GridCacheContext cctx,
byte state,
long crd,
long cntr,
int opCntr,
MvccSnapshot snapshot) |
| Constructor and Description |
|---|
StaticMvccQueryTracker(GridCacheContext cctx,
MvccSnapshot snapshot) |
| Modifier and Type | Class and Description |
|---|---|
class |
MvccSnapshotResponse |
| Modifier and Type | Method and Description |
|---|---|
MvccSnapshot |
MvccSnapshotResponse.withoutActiveTransactions() |
| 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) |
GridLongList |
GridCacheOffheapManager.GridCacheDataStore.mvccRemoveNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
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) |
GridLongList |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdateNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot 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,
Integer part,
String clsName,
String clause,
boolean incMeta,
boolean keepBinary,
UUID subjId,
int taskHash,
MvccSnapshot mvccSnapshot) |
GridCacheQueryRequest(int cacheId,
long id,
String cacheName,
GridCacheQueryType type,
boolean fields,
String clause,
String clsName,
IgniteBiPredicate<Object,Object> keyValFilter,
Integer part,
IgniteReducer<Object,Object> rdc,
IgniteClosure<?,?> trans,
int pageSize,
boolean incBackups,
Object[] args,
boolean incMeta,
boolean keepBinary,
UUID subjId,
int taskHash,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot,
boolean addDepInfo) |
| Modifier and Type | Field and Description |
|---|---|
protected MvccSnapshot |
IgniteTxAdapter.mvccSnapshot
Mvcc tx update snapshot.
|
| Modifier and Type | Method and Description |
|---|---|
MvccSnapshot |
IgniteTxAdapter.mvccSnapshot() |
MvccSnapshot |
IgniteInternalTx.mvccSnapshot() |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxLocalAdapter.markQueryEnlisted(MvccSnapshot ver) |
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) |
| Constructor and Description |
|---|
MvccUpdateDataRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
MvccSnapshot mvccSnapshot,
MvccVersion newVer,
CacheEntryPredicate filter,
boolean primary,
boolean lockOnly,
boolean needHist,
boolean fastUpdate,
boolean needOldVal,
boolean needPrevValue) |
MvccUpdateDataRowNative(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
MvccVersion newVer,
int part,
GridCacheContext cctx) |
| Constructor and Description |
|---|
MvccSnapshotSearchRow(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
UpdateSourceIterator<?> |
GridQueryIndexing.prepareDistributedUpdate(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.prepareDistributedUpdate(GridCacheContext<?,?> cctx,
int[] cacheIds,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
int timeout,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot,
GridQueryCancel cancel) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.5 Release Date : June 4 2019