| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.distributed.near.consistency |
| Modifier and Type | Class and Description |
|---|---|
class |
EntryGetWithTtlResult |
| Modifier and Type | Method and Description |
|---|---|
EntryGetResult |
GridCacheEntryEx.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
EntryGetResult |
GridCacheEntryEx.innerGetVersioned(@Nullable GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetVersioned(@Nullable GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
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).
|
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).
|
| Modifier and Type | Method and Description |
|---|---|
<K1,V1> void |
GridCacheContext.addResult(Map<K1,V1> map,
KeyCacheObject key,
CacheObject val,
boolean skipVals,
boolean keepCacheObjects,
boolean deserializeBinary,
boolean cpy,
@Nullable EntryGetResult getRes,
GridCacheVersion ver,
long expireTime,
long ttl,
boolean needVer,
@Nullable ClassLoader ldr) |
<K1,V1> void |
GridCacheContext.addResult(Map<K1,V1> map,
KeyCacheObject key,
EntryGetResult getRes,
boolean skipVals,
boolean keepCacheObjects,
boolean deserializeBinary,
boolean cpy,
boolean needVer) |
| Modifier and Type | Field and Description |
|---|---|
protected Map<ClusterNode,GridPartitionedGetFuture<KeyCacheObject,EntryGetResult>> |
GridNearReadRepairAbstractFuture.futs
Affinity node's get futures.
|
| Modifier and Type | Method and Description |
|---|---|
protected Map<KeyCacheObject,EntryGetResult> |
GridNearReadRepairAbstractFuture.check()
Checks consistency.
|
protected Map<KeyCacheObject,EntryGetResult> |
GridNearReadRepairAbstractFuture.correct(Set<KeyCacheObject> keys)
Calculates correct values.
|
Map<KeyCacheObject,EntryGetResult> |
GridNearReadRepairAbstractFuture.IgniteConsistencyRepairFailedException.correctedMap()
Repairable keys.
|
Map<KeyCacheObject,EntryGetResult> |
IgniteAtomicConsistencyViolationException.correctedMap() |
protected Map<KeyCacheObject,EntryGetResult> |
GridNearReadRepairAbstractFuture.correctWithPrimary(Collection<KeyCacheObject> inconsistentKeys) |
Map<KeyCacheObject,EntryGetResult> |
IgniteAtomicConsistencyViolationException.primaryMap() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridNearReadRepairCheckOnlyFuture.onDoneRepairRequired(Map<KeyCacheObject,EntryGetResult> correcredMap) |
protected void |
GridNearReadRepairAbstractFuture.onResult(IgniteInternalFuture<Map<KeyCacheObject,EntryGetResult>> finished)
Collects results of each 'get' future and prepares an overall result of the operation.
|
protected void |
GridNearReadRepairAbstractFuture.recordConsistencyViolation(Collection<KeyCacheObject> inconsistentKeys,
Map<KeyCacheObject,EntryGetResult> repairedEntries) |
| Constructor and Description |
|---|
IgniteAtomicConsistencyViolationException(Map<KeyCacheObject,EntryGetResult> correctedMap,
Map<KeyCacheObject,EntryGetResult> primaryMap,
Consumer<Map<KeyCacheObject,EntryGetResult>> callback) |
IgniteAtomicConsistencyViolationException(Map<KeyCacheObject,EntryGetResult> correctedMap,
Map<KeyCacheObject,EntryGetResult> primaryMap,
Consumer<Map<KeyCacheObject,EntryGetResult>> callback) |
IgniteAtomicConsistencyViolationException(Map<KeyCacheObject,EntryGetResult> correctedMap,
Map<KeyCacheObject,EntryGetResult> primaryMap,
Consumer<Map<KeyCacheObject,EntryGetResult>> callback) |
IgniteConsistencyRepairFailedException(Map<KeyCacheObject,EntryGetResult> correctedMap,
Set<KeyCacheObject> irreparableKeys) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.15.0 Release Date : April 25 2023