Class GridNearReadRepairCheckOnlyFuture
- java.lang.Object
-
- org.apache.ignite.internal.util.future.GridFutureAdapter<Map<KeyCacheObject,EntryGetResult>>
-
- org.apache.ignite.internal.processors.cache.distributed.near.consistency.GridNearReadRepairAbstractFuture
-
- org.apache.ignite.internal.processors.cache.distributed.near.consistency.GridNearReadRepairCheckOnlyFuture
-
- All Implemented Interfaces:
IgniteInternalFuture<Map<KeyCacheObject,EntryGetResult>>
public class GridNearReadRepairCheckOnlyFuture extends GridNearReadRepairAbstractFuture
Checks data consistency. Checks that each backup value equals to primary value.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.distributed.near.consistency.GridNearReadRepairAbstractFuture
GridNearReadRepairAbstractFuture.ByteArrayWrapper, GridNearReadRepairAbstractFuture.IgniteConsistencyCheckFailedException, GridNearReadRepairAbstractFuture.IgniteConsistencyRepairFailedException
-
-
Field Summary
-
Fields inherited from class org.apache.ignite.internal.processors.cache.distributed.near.consistency.GridNearReadRepairAbstractFuture
ctx, deserializeBinary, expiryPlc, futs, keys, MAX_REMAP_CNT, primaries, readThrough, recovery, remapCnt, strategy, taskName, tx
-
-
Constructor Summary
Constructors Constructor Description 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.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <K,V>
IgniteInternalFuture<Map<K,V>>multi()Returns a future represents entries map.protected voidonDoneIrreparable(Set<KeyCacheObject> irreparableKeys)protected voidonDoneRepairRequired(Map<KeyCacheObject,EntryGetResult> correcredMap)protected voidreduce()Reduces fut's results.protected GridNearReadRepairAbstractFutureremapFuture(AffinityTopologyVersion topVer)<K,V>
IgniteInternalFuture<V>single()Returns a future represents 1 entry's value.-
Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.near.consistency.GridNearReadRepairAbstractFuture
check, correct, correctWithPrimary, init, onResult, recordConsistencyViolation, remap
-
Methods inherited from class org.apache.ignite.internal.util.future.GridFutureAdapter
cancel, chain, chain, chain, chain, chainCompose, chainCompose, error, get, get, get, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, listen, logger, onCancelled, onDone, onDone, onDone, onDone, onDone, reset, result, toString
-
-
-
-
Constructor Detail
-
GridNearReadRepairCheckOnlyFuture
public 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.- Parameters:
topVer- Topology version.ctx- Cache context.keys- Keys.strategy- Read repair strategy.readThrough- Read-through flag.taskName- Task name.deserializeBinary- Deserialize binary flag.recovery- Partition recovery flag.expiryPlc- Expiry policy.skipVals- Skip values flag.needVer- Need version flag.keepCacheObjects- Keep cache objects flag.tx- Transaction. Can benullin case of atomic cache.
-
-
Method Detail
-
remapFuture
protected GridNearReadRepairAbstractFuture remapFuture(AffinityTopologyVersion topVer)
- Specified by:
remapFuturein classGridNearReadRepairAbstractFuture- Parameters:
topVer- Topology version.
-
reduce
protected void reduce()
Reduces fut's results.- Specified by:
reducein classGridNearReadRepairAbstractFuture
-
onDoneIrreparable
protected void onDoneIrreparable(Set<KeyCacheObject> irreparableKeys)
-
onDoneRepairRequired
protected void onDoneRepairRequired(Map<KeyCacheObject,EntryGetResult> correcredMap)
-
single
public <K,V> IgniteInternalFuture<V> single()
Returns a future represents 1 entry's value.- Returns:
- Future represents 1 entry's value.
-
multi
public <K,V> IgniteInternalFuture<Map<K,V>> multi()
Returns a future represents entries map.- Returns:
- Future represents entries map.
-
-