| Modifier and Type | Method and Description |
|---|---|
MvccVersion |
MvccDataEntry.mvccVer() |
MvccVersion |
MvccTxRecord.mvccVersion() |
| Constructor and Description |
|---|
LazyMvccDataEntry(GridCacheSharedContext cctx,
int cacheId,
byte keyType,
byte[] keyBytes,
byte valType,
byte[] valBytes,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
MvccVersion mvccVer) |
MvccDataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
MvccVersion mvccVer) |
MvccTxRecord(TransactionState state,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
Map<Short,Collection<Short>> participatingNodes,
MvccVersion mvccVer) |
MvccTxRecord(TransactionState state,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
Map<Short,Collection<Short>> participatingNodes,
MvccVersion mvccVer,
long ts) |
UnwrapMvccDataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
MvccVersion mvccVer,
CacheObjectValueContext cacheObjValCtx,
boolean keepBinary) |
| Modifier and Type | Method and Description |
|---|---|
List<IgniteBiTuple<Object,MvccVersion>> |
IgniteCacheOffheapManager.mvccAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
List<IgniteBiTuple<Object,MvccVersion>> |
IgniteCacheOffheapManagerImpl.mvccAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
List<IgniteBiTuple<Object,MvccVersion>> |
IgniteCacheOffheapManager.CacheDataStore.mvccFindAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
List<IgniteBiTuple<Object,MvccVersion>> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccFindAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
Sets new value if current version is 0
|
boolean |
GridCacheMapEntry.initialValue(CacheObject val,
GridCacheVersion ver,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
Sets new value if current version is 0
|
void |
IgniteCacheOffheapManager.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManagerImpl.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManager.CacheDataStore.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManager.mvccInitialValue(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManagerImpl.mvccInitialValue(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccInitialValueIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte txState,
byte newTxState) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccInitialValueIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte txState,
byte newTxState) |
boolean |
IgniteCacheOffheapManager.mvccInitialValueIfAbsent(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte txState,
byte newTxState) |
boolean |
IgniteCacheOffheapManagerImpl.mvccInitialValueIfAbsent(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte txState,
byte newTxState) |
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState) |
boolean |
IgniteCacheOffheapManager.mvccUpdateRowWithPreloadInfo(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState) |
boolean |
IgniteCacheOffheapManagerImpl.mvccUpdateRowWithPreloadInfo(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
MvccSnapshot
MVCC snapshot which holds the following information:
- Current MVCC version which should be used for visibility checks
- List of active transactions which should not be visible to current transaction
- Cleanup version which is used to help vacuum process.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MvccSnapshotWithoutTxs |
class |
MvccVersionImpl
Base MVCC version implementation.
|
| Modifier and Type | Field and Description |
|---|---|
static MvccVersion |
MvccUtils.INITIAL_VERSION |
static MvccVersion |
MvccUtils.MVCC_VERSION_NA |
| Modifier and Type | Method and Description |
|---|---|
static MvccVersion |
MvccUtils.getNewVersion(GridCacheContext cctx,
long link)
Returns new version of row (xid_max) if any.
|
MvccVersion |
MvccTxEntry.mvccVersion() |
default MvccVersion |
MvccVersionAware.mvccVersion() |
default MvccVersion |
MvccUpdateVersionAware.newMvccVersion() |
| Modifier and Type | Method and Description |
|---|---|
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) |
void |
MvccProcessor.ackTxRollback(MvccVersion updateVer) |
void |
MvccProcessorImpl.ackTxRollback(MvccVersion updateVer,
MvccSnapshot readSnapshot,
long qryTrackerId) |
void |
MvccProcessor.ackTxRollback(MvccVersion updateVer,
MvccSnapshot readSnapshot,
long qryTrackerId) |
void |
MvccCachingManager.addEnlisted(KeyCacheObject key,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
CacheObject oldVal,
boolean primary,
AffinityTopologyVersion topVer,
MvccVersion mvccVer,
int cacheId,
IgniteInternalTx tx,
IgniteUuid futId,
int batchNum)
Adds enlisted tx entry to cache.
|
static int |
MvccUtils.compare(MvccVersionAware row,
MvccVersion ver)
Compares row version (xid_min) with the given version.
|
static int |
MvccUtils.compare(MvccVersion mvccVerLeft,
long mvccCrdRight,
long mvccCntrRight)
Compares to pairs of MVCC versions.
|
static int |
MvccUtils.compare(MvccVersion mvccVerLeft,
long mvccCrdRight,
long mvccCntrRight,
int mvccOpCntrRight)
Compares to pairs of MVCC versions.
|
static int |
MvccUtils.compareIgnoreOpCounter(MvccVersion left,
MvccVersion right)
Compares left version (xid_min) with the given version ignoring operation counter.
|
static int |
MvccUtils.compareNewVersion(MvccUpdateVersionAware row,
MvccVersion ver)
Compares new row version (xid_max) with the given version.
|
default int |
MvccVersion.compareTo(MvccVersion another) |
default void |
MvccVersionAware.mvccVersion(MvccVersion ver)
Sets mvcc version.
|
default void |
MvccUpdateVersionAware.newMvccVersion(MvccVersion ver)
Sets new MVCC version
|
byte |
MvccProcessorImpl.state(MvccVersion ver) |
byte |
MvccProcessor.state(MvccVersion ver) |
void |
MvccProcessorImpl.updateState(MvccVersion ver,
byte state) |
void |
MvccProcessor.updateState(MvccVersion ver,
byte state) |
void |
MvccProcessorImpl.updateState(MvccVersion ver,
byte state,
boolean primary) |
void |
MvccProcessor.updateState(MvccVersion ver,
byte state,
boolean primary) |
IgniteInternalFuture<Void> |
MvccProcessorImpl.waitFor(GridCacheContext cctx,
MvccVersion locked) |
IgniteInternalFuture<Void> |
MvccProcessor.waitFor(GridCacheContext cctx,
MvccVersion locked) |
| Constructor and Description |
|---|
MvccTxEntry(KeyCacheObject key,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
CacheObject oldVal,
boolean primary,
AffinityTopologyVersion topVer,
MvccVersion mvccVer,
int cacheId) |
| Modifier and Type | Class and Description |
|---|---|
class |
MvccSnapshotResponse |
| Modifier and Type | Method and Description |
|---|---|
List<IgniteBiTuple<Object,MvccVersion>> |
GridCacheOffheapManager.GridCacheDataStore.mvccFindAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheOffheapManager.GridCacheDataStore.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccInitialValueIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte txState,
byte newTxState) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState) |
| Modifier and Type | Method and Description |
|---|---|
void |
DataPageIO.updateNewVersion(long pageAddr,
int dataOff,
MvccVersion newVer,
byte newTxState) |
void |
DataPageIO.updateVersion(long pageAddr,
int dataOff,
MvccVersion ver) |
| Modifier and Type | Method and Description |
|---|---|
MvccVersion |
TxRecordSerializer.readMvccVersion(ByteBufferBackedDataInput in)
Reads
MvccVersion from given input. |
| Modifier and Type | Method and Description |
|---|---|
void |
TxRecordSerializer.putMvccVersion(ByteBuffer buf,
MvccVersion mvccVer)
Writes
MvccVersion to given buffer. |
| Modifier and Type | Method and Description |
|---|---|
MvccVersion |
MvccUpdateResult.resultVersion() |
MvccVersion |
MvccUpdateDataRow.resultVersion() |
| Constructor and Description |
|---|
MvccDataRow(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
int cacheId,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
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) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.5 Release Date : June 4 2019