| Package | Description |
|---|---|
| org.apache.ignite.internal.pagemem.wal.record | |
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| 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 persitence implementation.
|
| org.apache.ignite.internal.processors.cache.persistence.wal.serializer | |
| org.apache.ignite.internal.processors.cache.tree.mvcc.data |
| 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,
@Nullable CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
MvccVersion mvccVer) |
MvccTxRecord(TransactionState state,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
@Nullable Map<Short,Collection<Short>> participatingNodes,
MvccVersion mvccVer) |
MvccTxRecord(TransactionState state,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
@Nullable 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 |
|---|---|
default boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
@Nullable MvccVersion mvccVer,
@Nullable 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
|
default boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
@Nullable MvccVersion mvccVer,
@Nullable 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 |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
@Nullable MvccVersion mvccVer,
@Nullable MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore,
@Nullable CacheDataRow row)
Sets new value if current version is 0
|
boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
@Nullable MvccVersion mvccVer,
@Nullable MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore,
@Nullable CacheDataRow row)
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,
CacheDataRow row)
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,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManager.mvccInitialValue(GridCacheMapEntry entry,
@Nullable 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.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
boolean |
IgniteCacheOffheapManager.mvccUpdateRowWithPreloadInfo(GridCacheMapEntry entry,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
boolean |
IgniteCacheOffheapManagerImpl.mvccUpdateRowWithPreloadInfo(GridCacheMapEntry entry,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
| 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
A special version visible by everyone
|
| 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 |
|---|---|
Optional<? extends MvccVersion> |
MvccProcessor.checkWaiting(MvccVersion mvccVer)
Checks whether one tx is waiting for another tx.
|
Optional<? extends MvccVersion> |
MvccProcessorImpl.checkWaiting(MvccVersion mvccVer)
Checks whether one tx is waiting for another tx.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MvccProcessor.ackTxRollback(MvccVersion updateVer) |
void |
MvccProcessorImpl.ackTxRollback(MvccVersion updateVer) |
void |
MvccCachingManager.addEnlisted(KeyCacheObject key,
@Nullable 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 boolean |
MvccUtils.belongToSameTx(MvccVersion v1,
MvccVersion v2) |
Optional<? extends MvccVersion> |
MvccProcessor.checkWaiting(MvccVersion mvccVer)
Checks whether one tx is waiting for another tx.
|
Optional<? extends MvccVersion> |
MvccProcessorImpl.checkWaiting(MvccVersion mvccVer)
Checks whether one tx is waiting for another tx.
|
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(@NotNull MvccVersion another) |
void |
MvccProcessor.failWaiter(MvccVersion mvccVer,
Exception e)
Unfreezes waiter for specific version failing it with passed exception.
|
void |
MvccProcessorImpl.failWaiter(MvccVersion mvccVer,
Exception e)
Unfreezes waiter for specific version failing it with passed exception.
|
DeadlockDetectionManager.DelayedDeadlockComputation |
DeadlockDetectionManager.initDelayedComputation(MvccVersion waiterVer,
MvccVersion blockerVer)
Starts a dedlock detection after a delay.
|
default void |
MvccVersionAware.mvccVersion(MvccVersion ver)
Sets mvcc version.
|
default void |
MvccUpdateVersionAware.newMvccVersion(MvccVersion ver)
Sets new MVCC version
|
void |
MvccProcessor.releaseWaiters(MvccVersion locked) |
void |
MvccProcessorImpl.releaseWaiters(MvccVersion locked) |
byte |
MvccProcessor.state(MvccVersion ver) |
byte |
MvccProcessorImpl.state(MvccVersion ver) |
void |
MvccProcessor.updateState(MvccVersion ver,
byte state) |
void |
MvccProcessorImpl.updateState(MvccVersion ver,
byte state) |
void |
MvccProcessor.updateState(MvccVersion ver,
byte state,
boolean primary) |
void |
MvccProcessorImpl.updateState(MvccVersion ver,
byte state,
boolean primary) |
IgniteInternalFuture<Void> |
MvccProcessor.waitForLock(GridCacheContext cctx,
MvccVersion waiterVer,
MvccVersion blockerVer)
Stands in the lock wait queue for the current lock holder.
|
IgniteInternalFuture<Void> |
MvccProcessorImpl.waitForLock(GridCacheContext cctx,
MvccVersion waiterVer,
MvccVersion blockerVer)
Stands in the lock wait queue for the current lock holder.
|
| Constructor and Description |
|---|
MvccTxEntry(KeyCacheObject key,
@Nullable 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,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
| 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 |
MvccUpdateDataRow.resultVersion() |
MvccVersion |
MvccUpdateResult.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,
@Nullable CacheEntryPredicate filter,
boolean primary,
boolean lockOnly,
boolean needHist,
boolean fastUpdate,
boolean needOldVal,
boolean needPrevValue) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.8.0 Release Date : February 27 2020