Class GridNearReadRepairFuture
- 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.GridNearReadRepairFuture
-
- All Implemented Interfaces:
IgniteInternalFuture<Map<KeyCacheObject,EntryGetResult>>
public class GridNearReadRepairFuture extends GridNearReadRepairAbstractFuture
Checks data consistency. Checks that each affinity node's value equals other's. Prepares recovery data. Records consistency violation event.
-
-
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 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.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidreduce()Reduces fut's results.protected GridNearReadRepairAbstractFutureremapFuture(AffinityTopologyVersion topVer)-
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
-
GridNearReadRepairFuture
public 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.- Parameters:
topVer- Affinity 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.tx- Transaction.
-
-
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
-
-