| 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.distributed.dht | |
| org.apache.ignite.internal.processors.cache.distributed.dht.atomic | |
| org.apache.ignite.internal.processors.cache.distributed.dht.colocated | |
| org.apache.ignite.internal.processors.cache.distributed.near | |
| org.apache.ignite.internal.processors.cache.transactions | |
| org.apache.ignite.internal.processors.query |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheOperation |
DataEntry.op
Entry operation performed.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheOperation |
DataEntry.op() |
| Constructor and Description |
|---|
DataEntry(int cacheId,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
byte flags) |
LazyDataEntry(GridCacheSharedContext cctx,
int cacheId,
byte keyType,
byte[] keyBytes,
byte valType,
byte[] valBytes,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
byte flags) |
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) |
UnwrapDataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
CacheObjectValueContext cacheObjValCtx,
boolean keepBinary,
byte flags) |
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 |
|---|---|
static @Nullable GridCacheOperation |
GridCacheOperation.fromOrdinal(int ord) |
static GridCacheOperation |
GridCacheOperation.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static GridCacheOperation[] |
GridCacheOperation.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
@Nullable Object val,
@Nullable Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
boolean readRepairRecovery,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long conflictTtl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
String taskName,
@Nullable CacheObject prevVal,
@Nullable Long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
@Nullable Object writeObj,
@Nullable Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
boolean readRepairRecovery,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long explicitTtl,
long explicitExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
String taskName,
@Nullable CacheObject prevVal,
@Nullable Long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
protected void |
GridCacheMapEntry.logUpdate(GridCacheOperation op,
CacheObject val,
GridCacheVersion writeVer,
long expireTime,
long updCntr,
boolean primary) |
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) |
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 | Method and Description |
|---|---|
void |
GridDhtTxRemote.addWrite(GridCacheContext cacheCtx,
GridCacheOperation op,
IgniteTxKey key,
@Nullable CacheObject val,
@Nullable Collection<T2<javax.cache.processor.EntryProcessor<Object,Object,Object>,Object[]>> entryProcessors,
long ttl,
boolean skipStore,
boolean keepBinary) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheOperation |
GridNearAtomicAbstractUpdateRequest.op
Update operation.
|
protected GridCacheOperation |
GridNearAtomicAbstractUpdateFuture.op
Update operation.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheOperation |
GridNearAtomicAbstractUpdateRequest.operation() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtAtomicSingleUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
void |
GridDhtAtomicUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
abstract void |
GridDhtAtomicAbstractUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
| Constructor and Description |
|---|
GridNearAtomicAbstractSingleUpdateRequest(int cacheId,
UUID nodeId,
long futId,
@NotNull AffinityTopologyVersion topVer,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
int taskNameHash,
byte flags,
boolean addDepInfo)
Constructor.
|
GridNearAtomicAbstractUpdateFuture(GridCacheContext cctx,
GridDhtAtomicCache cache,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
@Nullable Object[] invokeArgs,
boolean retval,
boolean rawRetval,
@Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
int taskNameHash,
boolean skipStore,
boolean keepBinary,
boolean recovery,
int remapCnt)
Constructor.
|
GridNearAtomicAbstractUpdateRequest(int cacheId,
UUID nodeId,
long futId,
@NotNull AffinityTopologyVersion topVer,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
int taskNameHash,
byte flags,
boolean addDepInfo)
Constructor.
|
GridNearAtomicSingleUpdateFuture(GridCacheContext cctx,
GridDhtAtomicCache cache,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
Object key,
@Nullable Object val,
@Nullable Object[] invokeArgs,
boolean retval,
boolean rawRetval,
@Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
int taskNameHash,
boolean skipStore,
boolean keepBinary,
boolean recovery,
int remapCnt) |
GridNearAtomicUpdateFuture(GridCacheContext cctx,
GridDhtAtomicCache cache,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
Collection<?> keys,
@Nullable Collection<?> vals,
@Nullable Object[] invokeArgs,
@Nullable Collection<GridCacheDrInfo> conflictPutVals,
@Nullable Collection<GridCacheVersion> conflictRmvVals,
boolean retval,
boolean rawRetval,
@Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
int taskNameHash,
boolean skipStore,
boolean keepBinary,
boolean recovery,
int remapCnt) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridDhtDetachedCacheEntry.logUpdate(GridCacheOperation op,
CacheObject val,
GridCacheVersion writeVer,
long expireTime,
long updCntr,
boolean primary) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridNearTxRemote.addEntry(GridCacheContext cacheCtx,
IgniteTxKey key,
GridCacheOperation op,
CacheObject val,
@Nullable GridCacheVersion drVer,
boolean skipStore,
boolean keepBinary) |
protected void |
GridNearCacheEntry.logUpdate(GridCacheOperation op,
CacheObject val,
GridCacheVersion ver,
long expireTime,
long updCntr,
boolean primary) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheOperation |
TxEntryValueHolder.op()
Gets cache operation.
|
GridCacheOperation |
IgniteTxEntry.op() |
@Nullable GridCacheOperation |
IgniteTxEntry.previousOperation() |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteBiTuple<GridCacheOperation,CacheObject> |
IgniteTxAdapter.applyTransformClosures(IgniteTxEntry txEntry,
boolean metrics,
@Nullable GridCacheReturn ret) |
protected IgniteBiTuple<GridCacheOperation,GridCacheVersionConflictContext> |
IgniteTxAdapter.conflictResolve(GridCacheOperation op,
IgniteTxEntry txEntry,
CacheObject newVal,
GridCacheVersion newVer,
GridCacheEntryEx old)
Resolve DR conflict.
|
T2<GridCacheOperation,CacheObject> |
IgniteTxEntry.entryProcessorCalculatedValue() |
| Modifier and Type | Method and Description |
|---|---|
IgniteTxEntry |
IgniteTxLocalAdapter.addEntry(GridCacheOperation op,
@Nullable CacheObject val,
@Nullable javax.cache.processor.EntryProcessor entryProcessor,
Object[] invokeArgs,
GridCacheEntryEx entry,
@Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
boolean filtersSet,
long drTtl,
long drExpireTime,
@Nullable GridCacheVersion drVer,
boolean skipStore,
boolean keepBinary,
boolean addReader) |
protected IgniteBiTuple<GridCacheOperation,GridCacheVersionConflictContext> |
IgniteTxAdapter.conflictResolve(GridCacheOperation op,
IgniteTxEntry txEntry,
CacheObject newVal,
GridCacheVersion newVer,
GridCacheEntryEx old)
Resolve DR conflict.
|
void |
TxEntryValueHolder.op(GridCacheOperation op)
Sets cache operation.
|
void |
IgniteTxEntry.op(GridCacheOperation op) |
void |
TxEntryValueHolder.value(GridCacheOperation op,
CacheObject val,
boolean hasWriteVal,
boolean hasReadVal) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxEntry.entryProcessorCalculatedValue(T2<GridCacheOperation,CacheObject> entryProcessorCalcVal) |
| Constructor and Description |
|---|
IgniteTxEntry(GridCacheContext<?,?> ctx,
IgniteInternalTx tx,
GridCacheOperation op,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
Object[] invokeArgs,
long ttl,
GridCacheEntryEx entry,
CacheEntryPredicate[] filters,
GridCacheVersion conflictVer,
boolean skipStore,
boolean keepBinary,
boolean addReader)
This constructor is meant for local transactions.
|
IgniteTxEntry(GridCacheContext<?,?> ctx,
IgniteInternalTx tx,
GridCacheOperation op,
CacheObject val,
long ttl,
long conflictExpireTime,
GridCacheEntryEx entry,
@Nullable GridCacheVersion conflictVer,
boolean skipStore,
boolean keepBinary)
This constructor is meant for remote transactions.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheOperation |
EnlistOperation.cacheOperation() |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.15.0 Release Date : April 25 2023