org.apache.ignite.internal.processors.cache.distributed.dht.atomic

Class GridDhtAtomicCache<K,V>

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheAdapter<K,V>

org.apache.ignite.internal.processors.cache.distributed.GridDistributedCacheAdapter<K,V>

org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtCacheAdapter<K,V>

org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache<K,V>

All Implemented Interfaces:

Externalizable, Serializable, Iterable<javax.cache.Cache.Entry<K,V>>, IgniteInternalCache<K,V>

@GridToStringExclude
public class GridDhtAtomicCache<K,V>
extends GridDhtCacheAdapter<K,V>

Non-transactional partitioned cache.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtCacheAdapter

GridDhtCacheAdapter.MessageHandler<M>

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.GridCacheAdapter

GridCacheAdapter.AsyncOp<T>, GridCacheAdapter.CacheExpiryPolicy, GridCacheAdapter.FutureHolder, GridCacheAdapter.InvokeAllTimeStatClosure<T>, GridCacheAdapter.PeekModes, GridCacheAdapter.TopologyVersionAwareJob, GridCacheAdapter.UpdateGetTimeStatClosure<T>, GridCacheAdapter.UpdatePutAndGetTimeStatClosure<T>, GridCacheAdapter.UpdatePutTimeStatClosure<T>, GridCacheAdapter.UpdateRemoveTimeStatClosure<T>, GridCacheAdapter.UpdateTimeStatClosure<T>

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheAdapter

cacheCfg, CLEAR_ALL_SPLIT_THRESHOLD, ctx, DFLT_START_CACHE_SIZE, keyCheck, lastFut, locNodeId, log, map, MAX_RETRIES, metrics, RET2NULL, txLockMsgLog

Constructor Summary

Constructors

Constructor and Description
GridDhtAtomicCache() Empty constructor required by Externalizable.
GridDhtAtomicCache(GridCacheContext<K,V> ctx)
GridDhtAtomicCache(GridCacheContext<K,V> ctx, GridCacheConcurrentMap map)

Method Summary

Modifier and Type	Method and Description
protected void	checkJta() Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
protected Map<K,V>	getAll(Collection<? extends K> keys, boolean deserializeBinary, boolean needVer, boolean recovery, boolean readRepair)
IgniteInternalFuture<Map<K,V>>	getAllAsync(@Nullable Collection<? extends K> keys, boolean forcePrimary, boolean skipTx, @Nullable UUID subjId, String taskName, boolean deserializeBinary, boolean recovery, boolean readRepair, boolean skipVals, boolean needVer)
protected V	getAndPut0(K key, V val, @Nullable CacheEntryPredicate filter)
IgniteInternalFuture<V>	getAndPutAsync0(K key, V val, @Nullable CacheEntryPredicate filter)
V	getAndRemove0(K key)
IgniteInternalFuture<V>	getAndRemoveAsync0(K key)
protected IgniteInternalFuture<V>	getAsync(K key, boolean forcePrimary, boolean skipTx, @Nullable UUID subjId, String taskName, boolean deserializeBinary, boolean skipVals, boolean needVer)
protected void	init() Post constructor initialization for subclasses.
<T> javax.cache.processor.EntryProcessorResult<T>	invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	invokeAll(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>>	invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>>	invokeAllAsync(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>>	invokeAsync(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
boolean	isDhtAtomic()
protected IgniteInternalFuture<Boolean>	lockAllAsync(Collection<KeyCacheObject> keys, long timeout, @Nullable IgniteTxLocalEx tx, boolean isInvalidate, boolean isRead, boolean retval, @Nullable TransactionIsolation isolation, long createTtl, long accessTtl)
GridNearCacheAdapter<K,V>	near()
void	near(GridNearAtomicCache<K,V> near)
protected boolean	put0(K key, V val, CacheEntryPredicate filter)
protected void	putAll0(Map<? extends K,? extends V> m)
IgniteInternalFuture<?>	putAllAsync0(Map<? extends K,? extends V> m)
void	putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> conflictMap) Store DR data.
IgniteInternalFuture<?>	putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> conflictMap) Store DR data asynchronously.
IgniteInternalFuture<Boolean>	putAsync0(K key, V val, @Nullable CacheEntryPredicate filter)
protected boolean	remove0(K key, CacheEntryPredicate filter)
protected void	removeAll0(Collection<? extends K> keys)
IgniteInternalFuture<Object>	removeAllAsync0(Collection<? extends K> keys)
void	removeAllConflict(Map<KeyCacheObject,GridCacheVersion> conflictMap) Removes DR data.
IgniteInternalFuture<?>	removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> conflictMap) Removes DR data asynchronously.
IgniteInternalFuture<Boolean>	removeAsync0(K key, @Nullable CacheEntryPredicate filter)
protected IgniteInternalFuture<Void>	repairAsync(Collection<? extends K> keys, CacheOperationContext opCtx, boolean skipVals) Checks the given keys and repairs entries across the topology if needed.
protected IgniteInternalFuture<Void>	repairAsync(K key, CacheOperationContext opCtx, boolean skipVals) Checks the given key and repairs entry across the topology if needed.
void	start() Starts this cache.
String	toString()

Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtCacheAdapter

addFuture, beginMultiUpdate, createEntry, dumpDebugInfo, endMultiUpdate, entryEx, entryExx, entryExx, getDhtAsync, localEntriesIterator, localLoad, localLoadCache, multiUpdateFinishFuture, multiUpdateTopologyFuture, needRemap, onDeferredDelete, onKernalStop, peekExx, preloader, primarySize, primarySizeLong, printMemoryStats, processForceKeyResponse, processForceKeysRequest, processNearGetRequest, processNearGetResponse, processNearSingleGetRequest, processNearSingleGetResponse, removeFuture, sendTtlUpdateRequest, size, sizeLong, splitClearLocally, topology, unlockAll

Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.GridDistributedCacheAdapter

localSizeLong, localSizeLong, lockAllAsync, removeAll, removeAllAsync, removeVersionedEntry, txLockAsync

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheAdapter

active, active, affinity, allEntries, asyncOp, asyncOpAcquire, asyncOpRelease, awaitLastFut, cache, checkCurrentTx, clear, clear, clearAll, clearAllAsync, clearAsync, clearAsync, clearLocally, clearLocally, clearLocally, clearLocallyAll, clusterMetrics, clusterMetrics, clusterMxBean, configuration, containsKey, containsKeyAsync, containsKeys, containsKeysAsync, context, decrementSize, entries, entryEx, entryEx, entrySet, entrySet, evict, evictAll, expiry, expiryPolicy, forceKeyCheck, forSubjectId, get, get, getAll, getAllAsync, getAllAsync, getAllAsync0, getAllOutTx, getAllOutTxAsync, getAndPut, getAndPut, getAndPutAsync, getAndPutAsync, getAndPutIfAbsent, getAndPutIfAbsentAsync, getAndRemove, getAndRemoveAsync, getAndReplace, getAndReplaceAsync, getAsync, getEntries, getEntriesAsync, getEntry, getEntryAsync, getForcePrimary, getForcePrimaryAsync, igfsDataSpaceUsed, igniteIterator, igniteIterator, incrementSize, invoke, isColocated, isDht, isEmpty, isIgfsDataCache, isLocal, isLocked, isLockedByThread, isNear, iterator, iterator, keepBinary, keySet, loadAll, localEntries, localLoadCacheAsync, localMetrics, localMxBean, localPeek, localPreloadPartition, localSize, lock, lockAll, lockAsync, log, lostPartitions, map, metrics0, name, nearSize, offHeapAllocatedSize, offHeapEntriesCount, onIgfsDataSizeChanged, onKernalStart, onReconnected, onUndeploy, parsePeekModes, peekEx, peekEx, preloadPartition, preloadPartitionAsync, put, put, putAll, putAllAsync, putAsync, putAsync, putIfAbsent, putIfAbsentAsync, readExternal, readResolve, rebalance, remove, remove, remove, removeAll, removeAllAsync, removeAsync, removeAsync, removeAsync, removeEntry, removeIfObsolete, removeMetrics, repairableGet, repairableGetAll, repairableGetAllAsync, repairableGetAsync, replace, replace, replaceAsync, replaceAsync, saveFuture, scanIterator, setSkipStore, size, sizeAsync, sizeLong, sizeLong, sizeLongAsync, sizeLongAsync, skipStore, startInfo, stop, stopInfo, tx, txStart, txStart, txStartEx, unlock, validateCacheKey, validateCacheKeys, withAllowAtomicOpsInTx, withExpiryPolicy, withNoRetries, writeExternal

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

GridDhtAtomicCache

public GridDhtAtomicCache()

Empty constructor required by Externalizable.

GridDhtAtomicCache

public GridDhtAtomicCache(GridCacheContext<K,V> ctx)

Parameters:

ctx - Cache context.

GridDhtAtomicCache

public GridDhtAtomicCache(GridCacheContext<K,V> ctx,
                          GridCacheConcurrentMap map)

Parameters:

ctx - Cache context.

map - Cache concurrent map.

Method Detail

checkJta

protected void checkJta()
                 throws IgniteCheckedException

Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.

Overrides:

checkJta in class GridCacheAdapter<K,V>

Throws:

IgniteCheckedException - In case of error.

isDhtAtomic

public boolean isDhtAtomic()

Overrides:

isDhtAtomic in class GridCacheAdapter<K,V>

Returns:

True if cache is DHT Atomic.

init

protected void init()

Post constructor initialization for subclasses.

Overrides:

init in class GridCacheAdapter<K,V>

start

public void start()
           throws IgniteCheckedException

Starts this cache. Child classes should override this method to provide custom start-up behavior.

Overrides:

start in class GridDhtCacheAdapter<K,V>

Throws:

IgniteCheckedException - If start failed.

near

public void near(GridNearAtomicCache<K,V> near)

Parameters:

near - Near cache.

near

public GridNearCacheAdapter<K,V> near()

Specified by:

near in class GridDhtCacheAdapter<K,V>

Returns:

Near cache.

getAsync

protected IgniteInternalFuture<V> getAsync(K key,
                                           boolean forcePrimary,
                                           boolean skipTx,
                                           @Nullable
                                           @Nullable UUID subjId,
                                           String taskName,
                                           boolean deserializeBinary,
                                           boolean skipVals,
                                           boolean needVer)

Overrides:

getAsync in class GridCacheAdapter<K,V>

Parameters:

key - Key.

forcePrimary - Force primary.

skipTx - Skip tx.

subjId - Subj Id.

taskName - Task name.

deserializeBinary - Deserialize binary.

skipVals - Skip values.

needVer - Need version.

Returns:

Future for the get operation.

getAll

protected Map<K,V> getAll(Collection<? extends K> keys,
                          boolean deserializeBinary,
                          boolean needVer,
                          boolean recovery,
                          boolean readRepair)
                   throws IgniteCheckedException

Overrides:

getAll in class GridCacheAdapter<K,V>

Parameters:

keys - Keys.

deserializeBinary - Deserialize binary flag.

needVer - Need version.

recovery - Recovery flag.

readRepair - Read repair flag.

Returns:

Map of cached values.

Throws:

IgniteCheckedException - If read failed.

getAllAsync

public IgniteInternalFuture<Map<K,V>> getAllAsync(@Nullable
                                                  @Nullable Collection<? extends K> keys,
                                                  boolean forcePrimary,
                                                  boolean skipTx,
                                                  @Nullable
                                                  @Nullable UUID subjId,
                                                  String taskName,
                                                  boolean deserializeBinary,
                                                  boolean recovery,
                                                  boolean readRepair,
                                                  boolean skipVals,
                                                  boolean needVer)

Overrides:

getAllAsync in class GridDhtCacheAdapter<K,V>

Parameters:

keys - Keys.

forcePrimary - Force primary.

skipTx - Skip tx.

subjId - Subj Id.

taskName - Task name.

deserializeBinary - Deserialize binary.

recovery - Recovery mode flag.

skipVals - Skip values.

needVer - Need version.

Returns:

Future for the get operation.

See Also:

GridCacheAdapter.getAllAsync(Collection)

getAndPut0

protected V getAndPut0(K key,
                       V val,
                       @Nullable
                       @Nullable CacheEntryPredicate filter)
                throws IgniteCheckedException

Overrides:

getAndPut0 in class GridCacheAdapter<K,V>

Parameters:

key - Key.

val - Value.

filter - Optional filter.

Returns:

Previous value.

Throws:

IgniteCheckedException - If failed.

put0

protected boolean put0(K key,
                       V val,
                       CacheEntryPredicate filter)
                throws IgniteCheckedException

Overrides:

put0 in class GridCacheAdapter<K,V>

Parameters:

key - Key.

val - Value.

filter - Filter.

Returns:

True if optional filter passed and value was stored in cache, false otherwise. Note that this method will return true if filter is not specified.

Throws:

IgniteCheckedException - If put operation failed.

getAndPutAsync0

public IgniteInternalFuture<V> getAndPutAsync0(K key,
                                               V val,
                                               @Nullable
                                               @Nullable CacheEntryPredicate filter)

Overrides:

getAndPutAsync0 in class GridCacheAdapter<K,V>

Parameters:

key - Key.

val - Value.

filter - Optional filter.

Returns:

Put operation future.

putAsync0

public IgniteInternalFuture<Boolean> putAsync0(K key,
                                               V val,
                                               @Nullable
                                               @Nullable CacheEntryPredicate filter)

Overrides:

putAsync0 in class GridCacheAdapter<K,V>

Parameters:

key - Key.

val - Value.

filter - Optional filter.

Returns:

Putx operation future.

putAll0

protected void putAll0(Map<? extends K,? extends V> m)
                throws IgniteCheckedException

Overrides:

putAll0 in class GridCacheAdapter<K,V>

Parameters:

m - Map.

Throws:

IgniteCheckedException - If failed.

putAllAsync0

public IgniteInternalFuture<?> putAllAsync0(Map<? extends K,? extends V> m)

Overrides:

putAllAsync0 in class GridCacheAdapter<K,V>

Parameters:

m - Map.

Returns:

Future.

putAllConflict

public void putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> conflictMap)
                    throws IgniteCheckedException

Store DR data.

Specified by:

putAllConflict in interface IgniteInternalCache<K,V>

Overrides:

putAllConflict in class GridCacheAdapter<K,V>

Parameters:

conflictMap - DR map.

Throws:

IgniteCheckedException - If put operation failed.

putAllConflictAsync

public IgniteInternalFuture<?> putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> conflictMap)

Store DR data asynchronously.

Specified by:

putAllConflictAsync in interface IgniteInternalCache<K,V>

Overrides:

putAllConflictAsync in class GridCacheAdapter<K,V>

Parameters:

conflictMap - DR map.

Returns:

Future.

getAndRemove0

public V getAndRemove0(K key)
                throws IgniteCheckedException

Overrides:

getAndRemove0 in class GridCacheAdapter<K,V>

Parameters:

key - Key.

Returns:

Previous value.

Throws:

IgniteCheckedException - If failed.

getAndRemoveAsync0

public IgniteInternalFuture<V> getAndRemoveAsync0(K key)

Overrides:

getAndRemoveAsync0 in class GridCacheAdapter<K,V>

Parameters:

key - Key.

Returns:

Future.

removeAll0

protected void removeAll0(Collection<? extends K> keys)
                   throws IgniteCheckedException

Overrides:

removeAll0 in class GridCacheAdapter<K,V>

Parameters:

keys - Keys.

Throws:

IgniteCheckedException - If failed.

removeAllAsync0

public IgniteInternalFuture<Object> removeAllAsync0(Collection<? extends K> keys)

Overrides:

removeAllAsync0 in class GridCacheAdapter<K,V>

Parameters:

keys - Keys.

Returns:

Future.

remove0

protected boolean remove0(K key,
                          CacheEntryPredicate filter)
                   throws IgniteCheckedException

Overrides:

remove0 in class GridCacheAdapter<K,V>

Parameters:

key - Key.

filter - Filter.

Returns:

True if entry was removed.

Throws:

IgniteCheckedException - If failed.

removeAsync0

public IgniteInternalFuture<Boolean> removeAsync0(K key,
                                                  @Nullable
                                                  @Nullable CacheEntryPredicate filter)

Overrides:

removeAsync0 in class GridCacheAdapter<K,V>

Parameters:

key - Key.

filter - Filter.

Returns:

Future.

removeAllConflict

public void removeAllConflict(Map<KeyCacheObject,GridCacheVersion> conflictMap)
                       throws IgniteCheckedException

Removes DR data.

Specified by:

removeAllConflict in interface IgniteInternalCache<K,V>

Overrides:

removeAllConflict in class GridCacheAdapter<K,V>

Parameters:

conflictMap - DR map.

Throws:

IgniteCheckedException - If remove failed.

removeAllConflictAsync

public IgniteInternalFuture<?> removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> conflictMap)

Removes DR data asynchronously.

Specified by:

removeAllConflictAsync in interface IgniteInternalCache<K,V>

Overrides:

removeAllConflictAsync in class GridCacheAdapter<K,V>

Parameters:

conflictMap - DR map.

Returns:

Future.

lockAllAsync

protected IgniteInternalFuture<Boolean> lockAllAsync(Collection<KeyCacheObject> keys,
                                                     long timeout,
                                                     @Nullable
                                                     @Nullable IgniteTxLocalEx tx,
                                                     boolean isInvalidate,
                                                     boolean isRead,
                                                     boolean retval,
                                                     @Nullable
                                                     @Nullable TransactionIsolation isolation,
                                                     long createTtl,
                                                     long accessTtl)

Specified by:

lockAllAsync in class GridDistributedCacheAdapter<K,V>

Parameters:

keys - Keys to lock.

timeout - Timeout.

tx - Transaction

isInvalidate - Invalidation flag.

isRead - Indicates whether value is read or written.

retval - Flag to return value.

isolation - Transaction isolation.

createTtl - TTL for create operation.

accessTtl - TTL for read operation.

Returns:

Future for locks.

invoke

public <T> javax.cache.processor.EntryProcessorResult<T> invoke(K key,
                                                                javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
                                                                Object... args)
                                                         throws IgniteCheckedException

Specified by:

invoke in interface IgniteInternalCache<K,V>

Overrides:

invoke in class GridCacheAdapter<K,V>

Parameters:

key - Key.

entryProcessor - Entry processor.

args - Arguments.

Returns:

Invoke result.

Throws:

IgniteCheckedException - If failed.

invokeAll

public <T> Map<K,javax.cache.processor.EntryProcessorResult<T>> invokeAll(Set<? extends K> keys,
                                                                          javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
                                                                          Object... args)
                                                                   throws IgniteCheckedException

Specified by:

invokeAll in interface IgniteInternalCache<K,V>

Overrides:

invokeAll in class GridCacheAdapter<K,V>

Parameters:

keys - Keys.

entryProcessor - Entry processor.

args - Arguments.

Returns:

Invoke results.

Throws:

IgniteCheckedException - If failed.

invokeAsync

public <T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>> invokeAsync(K key,
                                                                                           javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
                                                                                           Object... args)

Specified by:

invokeAsync in interface IgniteInternalCache<K,V>

Overrides:

invokeAsync in class GridCacheAdapter<K,V>

Parameters:

key - Key.

entryProcessor - Entry processor.

args - Arguments.

Returns:

Future.

invokeAllAsync

public <T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> invokeAllAsync(Set<? extends K> keys,
                                                                                                     javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
                                                                                                     Object... args)

Specified by:

invokeAllAsync in interface IgniteInternalCache<K,V>

Overrides:

invokeAllAsync in class GridCacheAdapter<K,V>

Parameters:

keys - Keys.

entryProcessor - Entry processor.

args - Arguments.

Returns:

Future.

invokeAll

public <T> Map<K,javax.cache.processor.EntryProcessorResult<T>> invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
                                                                          Object... args)
                                                                   throws IgniteCheckedException

Specified by:

invokeAll in interface IgniteInternalCache<K,V>

Overrides:

invokeAll in class GridCacheAdapter<K,V>

Parameters:

map - Map containing keys and entry processors to be applied to values.

args - Arguments.

Returns:

Invoke results.

Throws:

IgniteCheckedException - If failed.

invokeAllAsync

public <T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
                                                                                                     Object... args)

Specified by:

invokeAllAsync in interface IgniteInternalCache<K,V>

Overrides:

invokeAllAsync in class GridCacheAdapter<K,V>

Parameters:

map - Map containing keys and entry processors to be applied to values.

args - Arguments.

Returns:

Future.

repairAsync

protected IgniteInternalFuture<Void> repairAsync(Collection<? extends K> keys,
                                                 CacheOperationContext opCtx,
                                                 boolean skipVals)

Checks the given keys and repairs entries across the topology if needed.

Overrides:

repairAsync in class GridCacheAdapter<K,V>

Parameters:

keys - Keys.

opCtx - Operation context.

skipVals - Skip values flag.

Returns:

Compound future that represents a result of repair action.

repairAsync

protected IgniteInternalFuture<Void> repairAsync(K key,
                                                 CacheOperationContext opCtx,
                                                 boolean skipVals)

Checks the given key and repairs entry across the topology if needed.

Overrides:

repairAsync in class GridCacheAdapter<K,V>

Parameters:

key - Key.

opCtx - Operation context.

skipVals - Skip values flag.

Returns:

Recover future.

toString

public String toString()

Overrides:

toString in class GridDhtCacheAdapter<K,V>