| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| org.apache.ignite.cache |
Contains main Data Grid APIs.
|
| org.apache.ignite.events |
Contains Event Subscription functionality together with various events emitted by Ignite.
|
| 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.distributed.near.consistency | |
| org.apache.ignite.internal.visor.consistency |
| Modifier and Type | Method and Description |
|---|---|
IgniteCache<K,V> |
IgniteCache.withReadRepair(ReadRepairStrategy strategy)
This is an experimental API.
|
| Modifier and Type | Method and Description |
|---|---|
static ReadRepairStrategy |
ReadRepairStrategy.fromString(String name)
Provides strategy by name.
|
static ReadRepairStrategy |
ReadRepairStrategy.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ReadRepairStrategy[] |
ReadRepairStrategy.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
ReadRepairStrategy |
CacheConsistencyViolationEvent.getStrategy()
Returns strategy.
|
| Constructor and Description |
|---|
CacheConsistencyViolationEvent(String cacheName,
ClusterNode node,
String msg,
Map<Object,CacheConsistencyViolationEvent.EntriesInfo> entries,
Map<Object,Object> repaired,
ReadRepairStrategy strategy)
Creates a new instance of CacheConsistencyViolationEvent.
|
| Modifier and Type | Method and Description |
|---|---|
ReadRepairStrategy |
CacheOperationContext.readRepairStrategy() |
| Modifier and Type | Method and Description |
|---|---|
protected Map<K,V> |
GridCacheAdapter.getAll(Collection<? extends K> keys,
boolean deserializeBinary,
boolean needVer,
boolean recovery,
ReadRepairStrategy readRepairStrategy) |
protected IgniteInternalFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(@Nullable Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
String taskName,
boolean deserializeBinary,
boolean recovery,
ReadRepairStrategy readRepairStrategy,
boolean skipVals,
boolean needVer) |
IgniteInternalFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(@Nullable Collection<? extends K> keys,
@Nullable ReaderArguments readerArgs,
boolean readThrough,
boolean checkTx,
String taskName,
boolean deserializeBinary,
boolean recovery,
ReadRepairStrategy readRepairStrategy,
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,
String taskName,
boolean deserializeBinary,
@Nullable IgniteCacheExpiryPolicy expiry,
boolean skipVals,
boolean keepCacheObjects,
boolean recovery,
ReadRepairStrategy readRepairStrategy,
boolean needVer,
@Nullable String txLbl,
MvccSnapshot mvccSnapshot) |
protected Map<K,V> |
GridCacheAdapter.repairableGetAll(Collection<? extends K> keys,
boolean deserializeBinary,
boolean needVer,
boolean recovery,
ReadRepairStrategy readRepairStrategy) |
IgniteInternalFuture<Map<K,V>> |
GridCacheAdapter.repairableGetAllAsync(@Nullable Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
String taskName,
boolean deserializeBinary,
boolean recovery,
ReadRepairStrategy readRepairStrategy,
boolean skipVals,
boolean needVer) |
IgniteInternalFuture<V> |
GridCacheAdapter.repairableGetAsync(K key,
boolean deserializeBinary,
boolean needVer,
ReadRepairStrategy readRepairStrategy) |
CacheOperationContext |
CacheOperationContext.setReadRepairStrategy(ReadRepairStrategy readRepairStrategy) |
IgniteCache<K,V> |
GatewayProtectedCacheProxy.withReadRepair(ReadRepairStrategy strategy)
This is an experimental API.
|
IgniteCache<K,V> |
IgniteCacheProxyImpl.withReadRepair(ReadRepairStrategy strategy)
This is an experimental API.
|
| Constructor and Description |
|---|
CacheOperationContext(boolean skipStore,
boolean keepBinary,
@Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean noRetries,
@Nullable Byte dataCenterId,
boolean recovery,
@Nullable ReadRepairStrategy readRepairStrategy,
boolean allowAtomicOpsInTx) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridDhtCacheAdapter.getAllAsync(@Nullable Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
String taskName,
boolean deserializeBinary,
boolean recovery,
ReadRepairStrategy readRepairStrategy,
boolean skipVals,
boolean needVer) |
| Modifier and Type | Method and Description |
|---|---|
protected Map<K,V> |
GridDhtAtomicCache.getAll(Collection<? extends K> keys,
boolean deserializeBinary,
boolean needVer,
boolean recovery,
ReadRepairStrategy readRepairStrategy) |
IgniteInternalFuture<Map<K,V>> |
GridDhtAtomicCache.getAllAsync(@Nullable Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
String taskName,
boolean deserializeBinary,
boolean recovery,
ReadRepairStrategy readRepairStrategy,
boolean skipVals,
boolean needVer) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridDhtColocatedCache.getAllAsync(@Nullable Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
String taskName,
boolean deserializeBinary,
boolean recovery,
ReadRepairStrategy readRepairStrategy,
boolean skipVals,
boolean needVer) |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteInternalFuture<Map<K,V>> |
GridNearAtomicCache.getAllAsync(@Nullable Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
String taskName,
boolean deserializeBinary,
boolean recovery,
ReadRepairStrategy readRepairStrategy,
boolean skipVals,
boolean needVer) |
IgniteInternalFuture<Map<K,V>> |
GridNearTransactionalCache.getAllAsync(@Nullable Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
String taskName,
boolean deserializeBinary,
boolean recovery,
ReadRepairStrategy readRepairStrategy,
boolean skipVals,
boolean needVer) |
<K,V> IgniteInternalFuture<Map<K,V>> |
GridNearTxLocal.getAllAsync(GridCacheContext cacheCtx,
@Nullable AffinityTopologyVersion entryTopVer,
Collection<KeyCacheObject> keys,
boolean deserializeBinary,
boolean skipVals,
boolean keepCacheObjects,
boolean skipStore,
boolean recovery,
ReadRepairStrategy readRepairStrategy,
boolean needVer) |
| Modifier and Type | Field and Description |
|---|---|
protected ReadRepairStrategy |
GridNearReadRepairAbstractFuture.strategy
Strategy.
|
| Constructor and Description |
|---|
GridNearReadRepairAbstractFuture(AffinityTopologyVersion topVer,
GridCacheContext<?,?> ctx,
Collection<KeyCacheObject> keys,
ReadRepairStrategy strategy,
boolean readThrough,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
IgniteInternalTx tx,
GridNearReadRepairAbstractFuture remappedFut)
Creates a new instance of GridNearReadRepairAbstractFuture.
|
GridNearReadRepairCheckOnlyFuture(AffinityTopologyVersion topVer,
GridCacheContext<?,?> ctx,
Collection<KeyCacheObject> keys,
ReadRepairStrategy strategy,
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,
ReadRepairStrategy strategy,
boolean readThrough,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
IgniteInternalTx tx)
Creates a new instance of GridNearReadRepairFuture.
|
| Modifier and Type | Method and Description |
|---|---|
ReadRepairStrategy |
VisorConsistencyRepairTaskArg.strategy() |
| Constructor and Description |
|---|
VisorConsistencyRepairTaskArg(String cacheOrGrpName,
Collection<Integer> parts,
ReadRepairStrategy strategy) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.15.0 Release Date : April 25 2023