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

Class GridDhtTransactionalCacheAdapter<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.GridDhtTransactionalCacheAdapter<K,V>

All Implemented Interfaces:

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

Direct Known Subclasses:

GridDhtCache, GridDhtColocatedCache

public abstract class GridDhtTransactionalCacheAdapter<K,V>
extends GridDhtCacheAdapter<K,V>

Base class for transactional DHT caches.

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.distributed.GridDistributedCacheAdapter

GridDistributedCacheAdapter.GlobalRemoveAllJob<K,V>

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

GridCacheAdapter.AsyncOp<T>, GridCacheAdapter.AtomicReadRepairEntryProcessor<K,V>, GridCacheAdapter.BulkOperation, GridCacheAdapter.CacheExpiryPolicy, GridCacheAdapter.FutureHolder, GridCacheAdapter.InvokeAllTimeStatClosure<T>, GridCacheAdapter.PeekModes, GridCacheAdapter.TopologyVersionAwareJob, GridCacheAdapter.UpdateGetAllTimeStatClosure<T>, GridCacheAdapter.UpdateGetAndRemoveTimeStatClosure<T>, GridCacheAdapter.UpdateGetTimeStatClosure<T>, GridCacheAdapter.UpdatePutAllConflictTimeStatClosure<T>, GridCacheAdapter.UpdatePutAllTimeStatClosure<T>, GridCacheAdapter.UpdatePutAndGetTimeStatClosure<T>, GridCacheAdapter.UpdatePutTimeStatClosure<T>, GridCacheAdapter.UpdateRemoveAllConflictTimeStatClosure<T>, GridCacheAdapter.UpdateRemoveAllTimeStatClosure<T>, GridCacheAdapter.UpdateRemoveTimeStatClosure, GridCacheAdapter.UpdateTimeStatClosure<T>

Field Summary

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

cacheCfg, CLEAR_ALL_SPLIT_THRESHOLD, ctx, DFLT_CACHE_RETRIES_COUNT, DFLT_CACHE_START_SIZE, DFLT_START_CACHE_SIZE, lastFut, locNodeId, log, map, MAX_RETRIES, metrics, NON_TRANSACTIONAL_IGNITE_CACHE_CLEAR_IN_TX_ERROR_MESSAGE, RET2NULL, txLockMsgLog

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GridDhtTransactionalCacheAdapter()	Empty constructor required for Externalizable.
protected	GridDhtTransactionalCacheAdapter(GridCacheContext<K,V> ctx)
protected	GridDhtTransactionalCacheAdapter(GridCacheContext<K,V> ctx, GridCacheConcurrentMap map)	Constructor used for near-only cache.

Method Summary

Modifier and Type	Method	Description
IgniteInternalFuture<Boolean>	lockAllAsync(@Nullable Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx txx, boolean isInvalidate, boolean isRead, boolean retval, TransactionIsolation isolation, long createTtl, long accessTtl)
IgniteInternalFuture<GridNearLockResponse>	lockAllAsync(GridCacheContext<?,?> cacheCtx, ClusterNode nearNode, GridNearLockRequest req)
GridDhtFuture<Boolean>	lockAllAsyncInternal(@Nullable Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx txx, boolean isInvalidate, boolean isRead, boolean retval, TransactionIsolation isolation, long createTtl, long accessTtl, boolean skipStore, boolean keepBinary)	Acquires locks in partitioned cache.
abstract GridNearTransactionalCache<K,V>	near()
void	onKernalStart()	Kernal start callback.
void	removeLocks(UUID nodeId, GridCacheVersion ver, Iterable<KeyCacheObject> keys, boolean unmap)

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

addFuture, createEntry, dumpDebugInfo, entryEx, entryExx, entryExx, getAllAsync, getDhtAsync, localEntriesIterator, localLoad, localLoadCache, needRemap, onDeferredDelete, onKernalStop, peekExx, preloader, primarySize, primarySizeLong, printMemoryStats, processForceKeyResponse, processForceKeysRequest, processNearGetRequest, processNearGetResponse, processNearSingleGetRequest, processNearSingleGetResponse, removeFuture, sendTtlUpdateRequest, size, sizeLong, splitClearLocally, topology, toString, 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, cache, checkJta, clear, clear, clearAll, clearAllAsync, clearAsync, clearAsync, clearLocally, clearLocally, clearLocally, clearLocallyAll, clusterMetrics, clusterMetrics, configuration, containsKey, containsKeyAsync, containsKeys, containsKeysAsync, context, decrementSize, entries, entryEx, entryEx, entrySet, entrySet, evict, evictAll, expiry, expiryPolicy, get, get, getAll, getAll, getAllAsync, getAllOutTx, getAllOutTxAsync, getAndPut, getAndPut, getAndPut0, getAndPutAsync, getAndPutAsync, getAndPutAsync0, getAndPutIfAbsent, getAndPutIfAbsentAsync, getAndRemove, getAndRemove0, getAndRemoveAsync, getAndRemoveAsync0, getAndReplace, getAndReplaceAsync, getAsync, getAsync, getEntries, getEntriesAsync, getEntry, getEntryAsync, getForcePrimary, getForcePrimaryAsync, igniteIterator, igniteIterator, incrementSize, init, invoke, invoke, invokeAll, invokeAll, invokeAllAsync, invokeAllAsync, invokeAsync, isColocated, isDht, isDhtAtomic, isEmpty, isLocal, isLocked, isLockedByThread, isNear, iterator, iterator, keepBinary, keySet, lastAsyncFuture, loadAll, localEntries, localLoadCacheAsync, localMetrics, localPeek, localPreloadPartition, localSize, lock, lockAll, lockAsync, log, lostPartitions, map, metrics0, name, nearSize, nextVersion, nextVersion, offHeapAllocatedSize, offHeapEntriesCount, onReconnected, onUndeploy, parsePeekModes, peekEx, peekEx, preloadPartition, preloadPartitionAsync, put, put, put0, putAll, putAll0, putAllAsync, putAllAsync0, putAllConflict, putAllConflictAsync, putAsync, putAsync, putAsync0, putIfAbsent, putIfAbsentAsync, readExternal, readResolve, rebalance, remove, remove, remove, remove0, removeAll, removeAll0, removeAllAsync, removeAllAsync0, removeAllConflict, removeAllConflictAsync, removeAsync, removeAsync, removeAsync, removeAsync0, removeEntry, removeIfObsolete, removeMetrics, repairableGet, repairableGetAll, repairableGetAllAsync, repairableGetAsync, replace, replace, replaceAsync, replaceAsync, scanIterator, setSkipStore, size, sizeAsync, sizeLong, sizeLong, sizeLongAsync, sizeLongAsync, skipStore, start, startInfo, stop, stopInfo, tx, txStart, txStart, txStartEx, unlock, warnIfUnordered, warnIfUnordered, 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

GridDhtTransactionalCacheAdapter

protected GridDhtTransactionalCacheAdapter()

Empty constructor required for Externalizable.

GridDhtTransactionalCacheAdapter

protected GridDhtTransactionalCacheAdapter(GridCacheContext<K,V> ctx)

Parameters:

ctx - Context.

GridDhtTransactionalCacheAdapter

protected GridDhtTransactionalCacheAdapter(GridCacheContext<K,V> ctx,
                                           GridCacheConcurrentMap map)

Constructor used for near-only cache.

Parameters:

ctx - Cache context.

map - Cache map.

Method Detail

onKernalStart

public void onKernalStart()
                   throws IgniteCheckedException

Kernal start callback.

Overrides:

onKernalStart in class GridDhtCacheAdapter<K,V>

Throws:

IgniteCheckedException - If callback failed.

near

public abstract GridNearTransactionalCache<K,V> near()

Specified by:

near in class GridDhtCacheAdapter<K,V>

Returns:

Near cache.

lockAllAsync

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

Specified by:

lockAllAsync in class GridDistributedCacheAdapter<K,V>

Parameters:

keys - Keys to lock.

timeout - Timeout.

txx - 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.

lockAllAsyncInternal

public GridDhtFuture<Boolean> lockAllAsyncInternal(@Nullable
                                                   @Nullable Collection<KeyCacheObject> keys,
                                                   long timeout,
                                                   IgniteTxLocalEx txx,
                                                   boolean isInvalidate,
                                                   boolean isRead,
                                                   boolean retval,
                                                   TransactionIsolation isolation,
                                                   long createTtl,
                                                   long accessTtl,
                                                   boolean skipStore,
                                                   boolean keepBinary)

Acquires locks in partitioned cache.

Parameters:

keys - Keys to lock.

timeout - Lock timeout.

txx - Transaction.

isInvalidate - Invalidate flag.

isRead - Read flag.

retval - Return value flag.

isolation - Transaction isolation.

createTtl - TTL for create operation.

accessTtl - TTL for read operation.

skipStore - Skip store flag.

Returns:

Lock future.

lockAllAsync

public IgniteInternalFuture<GridNearLockResponse> lockAllAsync(GridCacheContext<?,?> cacheCtx,
                                                               ClusterNode nearNode,
                                                               GridNearLockRequest req)

Parameters:

cacheCtx - Cache context.

nearNode - Near node.

req - Request.

Returns:

Future.

removeLocks

public void removeLocks(UUID nodeId,
                        GridCacheVersion ver,
                        Iterable<KeyCacheObject> keys,
                        boolean unmap)

Parameters:

nodeId - Node ID.

ver - Version.

keys - Keys.

unmap - Flag for un-mapping version.