| Package | Description |
|---|---|
| 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.distributed.near.consistency | |
| org.apache.ignite.internal.processors.cache.transactions |
| Modifier and Type | Class and Description |
|---|---|
protected static class |
GridCacheAdapter.CacheExpiryPolicy |
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteCacheExpiryPolicy |
GridCacheAdapter.expiryPolicy(@Nullable javax.cache.expiry.ExpiryPolicy plc) |
| Modifier and Type | Method and Description |
|---|---|
static @Nullable GridCacheUtils.BackupPostProcessingClosure |
GridCacheUtils.createBackupPostProcessingClosure(AffinityTopologyVersion topVer,
IgniteLogger log,
GridCacheContext cctx,
@Nullable KeyCacheObject key,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean readThrough,
boolean skipVals)
Creates closure that saves initial value to backup partition.
|
IgniteInternalFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(@Nullable Collection<? extends K> keys,
@Nullable ReaderArguments readerArgs,
boolean readThrough,
boolean checkTx,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
boolean recovery,
boolean readRepair,
boolean forcePrimary,
@Nullable IgniteCacheExpiryPolicy expiry,
boolean skipVals,
boolean needVer) |
protected <K1,V1> IgniteInternalFuture<Map<K1,V1>> |
GridCacheAdapter.getAllAsync0(@Nullable Collection<KeyCacheObject> keys,
@Nullable ReaderArguments readerArgs,
boolean readThrough,
boolean checkTx,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
@Nullable IgniteCacheExpiryPolicy expiry,
boolean skipVals,
boolean keepCacheObjects,
boolean recovery,
boolean readRepair,
boolean needVer,
@Nullable String txLbl,
MvccSnapshot mvccSnapshot) |
CacheObject |
GridCacheMapEntry.innerGet(@Nullable GridCacheVersion ver,
@Nullable IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expirePlc,
boolean keepBinary) |
CacheObject |
GridCacheEntryEx.innerGet(@Nullable GridCacheVersion ver,
@Nullable IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary) |
EntryGetResult |
GridCacheMapEntry.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
UUID subjId,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
EntryGetResult |
GridCacheEntryEx.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
UUID subjId,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetVersioned(@Nullable GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
EntryGetResult |
GridCacheEntryEx.innerGetVersioned(@Nullable GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
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,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long explicitTtl,
long explicitExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
@Nullable UUID subjId,
String taskName,
@Nullable CacheObject prevVal,
@Nullable Long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
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,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long conflictTtl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
@Nullable UUID subjId,
String taskName,
@Nullable CacheObject prevVal,
@Nullable Long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
@Nullable CacheObject |
GridCacheMapEntry.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
@Nullable IgniteCacheExpiryPolicy expiryPlc)
Peeks into entry without loading value or updating statistics.
|
@Nullable CacheObject |
GridCacheEntryEx.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
@Nullable IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
boolean |
GridCacheContext.readNoEntry(@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean readers)
Checks if it is possible to directly read data memory without entry creation (this
is optimization to avoid unnecessary blocking synchronization on cache entry).
|
EntryGetResult |
GridCacheMapEntry.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer,
@Nullable IgniteCacheExpiryPolicy loadExpiryPlc,
@Nullable ReaderArguments readerArgs)
Sets new value if passed in version matches the current version
(used for read-through only).
|
EntryGetResult |
GridCacheEntryEx.versionedValue(CacheObject val,
@Nullable GridCacheVersion curVer,
@Nullable GridCacheVersion newVer,
@Nullable IgniteCacheExpiryPolicy loadExpiryPlc,
@Nullable ReaderArguments readerArgs)
Sets new value if passed in version matches the current version
(used for read-through only).
|
| Modifier and Type | Field and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
CacheDistributedGetFutureAdapter.expiryPlc
Expiry policy.
|
| 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,
@Nullable UUID subjId,
int taskNameHash,
@Nullable IgniteCacheExpiryPolicy expiry,
boolean skipVals,
boolean recovery,
@Nullable String txLbl,
MvccSnapshot mvccSnapshot) |
void |
GridDhtCacheAdapter.sendTtlUpdateRequest(@Nullable IgniteCacheExpiryPolicy expiryPlc) |
| Constructor and Description |
|---|
CacheDistributedGetFutureAdapter(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
boolean recovery) |
GridDhtGetFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
@NotNull AffinityTopologyVersion topVer,
@Nullable UUID subjId,
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,
@Nullable UUID subjId,
int taskNameHash,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean recovery,
@Nullable String txLbl,
@Nullable MvccSnapshot mvccSnapshot) |
GridPartitionedGetFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
@Nullable UUID subjId,
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,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
boolean recovery,
String txLbl,
@Nullable MvccSnapshot mvccSnapshot) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridDhtColocatedCache.loadAsync(@Nullable Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
AffinityTopologyVersion topVer,
@Nullable UUID subjId,
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,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObj,
boolean recovery,
@Nullable MvccSnapshot mvccSnapshot,
@Nullable String txLbl) |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
GridNearTxLocal.accessPolicy(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys) |
protected IgniteCacheExpiryPolicy |
GridNearTxLocal.accessPolicy(GridCacheContext ctx,
IgniteTxKey key,
@Nullable javax.cache.expiry.ExpiryPolicy expiryPlc) |
| Constructor and Description |
|---|
GridNearGetFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
@Nullable IgniteTxLocalEx tx,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
boolean recovery) |
| Modifier and Type | Field and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
GridNearReadRepairAbstractFuture.expiryPlc
Expiry policy flag.
|
| Constructor and Description |
|---|
GridNearReadRepairAbstractFuture(AffinityTopologyVersion topVer,
GridCacheContext<KeyCacheObject,EntryGetResult> ctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
IgniteInternalTx tx)
Creates a new instance of GridNearReadRepairAbstractFuture.
|
GridNearReadRepairCheckOnlyFuture(GridCacheContext ctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
IgniteInternalTx tx)
Creates a new instance of GridNearReadRepairCheckOnlyFuture.
|
GridNearReadRepairFuture(AffinityTopologyVersion topVer,
GridCacheContext ctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
IgniteInternalTx tx)
Creates a new instance of GridNearReadRepairFuture.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
IgniteTxLocalAdapter.accessPolicy(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys) |
protected IgniteCacheExpiryPolicy |
IgniteTxLocalAdapter.accessPolicy(GridCacheContext ctx,
IgniteTxKey key,
@Nullable javax.cache.expiry.ExpiryPolicy expiryPlc) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.8.1 Release Date : May 21 2020