org.apache.ignite.internal.processors.cache.distributed.near.consistency

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 and 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

Modifier and Type	Method and Description
<K,V> IgniteInternalFuture<Map<K,V>>	multi() Returns a future represents entries map.
protected void	onDoneIrreparable(Set<KeyCacheObject> irreparableKeys)
protected void	onDoneRepairRequired(Map<KeyCacheObject,EntryGetResult> correcredMap)
protected void	reduce() Reduces fut's results.
protected GridNearReadRepairAbstractFuture	remapFuture(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, chainCompose, chainCompose, error, get, get, get, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, logger, onCancelled, onDone, onDone, onDone, onDone, onDone, reset, result, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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 be null in case of atomic cache.

Method Detail

remapFuture

protected GridNearReadRepairAbstractFuture remapFuture(AffinityTopologyVersion topVer)

Specified by:

remapFuture in class GridNearReadRepairAbstractFuture

Parameters:

topVer - Topology version.

reduce

protected void reduce()

Reduces fut's results.

Specified by:

reduce in class GridNearReadRepairAbstractFuture

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.