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.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.distributed.near.consistency.GridNearReadRepairAbstractFuture

ctx, deserializeBinary, expiryPlc, futs, keys, MAX_REMAP_CNT, readThrough, recovery, REMAP_CNT_UPD, remapCnt, taskName, tx

Constructor Summary

Constructors

Constructor and Description
GridNearReadRepairCheckOnlyFuture(GridCacheContext ctx, Collection<KeyCacheObject> keys, 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	reduce() Reduces fut's results.
<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

map, onResult

Methods inherited from class org.apache.ignite.internal.util.future.GridFutureAdapter

cancel, chain, chain, 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(GridCacheContext ctx,
                                         Collection<KeyCacheObject> keys,
                                         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:

ctx - Cache context.

keys - Keys.

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

reduce

protected void reduce()

Reduces fut's results.

Specified by:

reduce in class GridNearReadRepairAbstractFuture

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.