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

Class GridNearTransactionalCache<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.near.GridNearCacheAdapter<K,V>

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

All Implemented Interfaces:

Externalizable, Serializable, Iterable<javax.cache.Cache.Entry<K,V>>, GridCache<K,V>, CacheProjection<K,V>, GridCacheProjectionEx<K,V>

public class GridNearTransactionalCache<K,V>
extends GridNearCacheAdapter<K,V>

Near cache for transactional cache.

See Also:

Serialized Form

Nested Class Summary

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

GridCacheAdapter.AsyncOp<T>, GridCacheAdapter.CacheExpiryPolicy, GridCacheAdapter.FutureHolder, 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, gridCfg, keyCheck, lastFut, locNodeId, log, map, metrics, mxBean, RET2NULL

Constructor Summary

Constructors

Constructor and Description
GridNearTransactionalCache() Empty constructor required for Externalizable.
GridNearTransactionalCache(GridCacheContext<K,V> ctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	clearLocks(UUID nodeId, GridDhtUnlockRequest req)
GridDhtCache<K,V>	dht()
void	dht(GridDhtCache<K,V> dht)
protected boolean	evictNearEntry(GridCacheEntryEx e, GridCacheVersion obsoleteVer, long topVer)
IgniteInternalFuture<Map<K,V>>	getAllAsync(Collection<? extends K> keys, boolean forcePrimary, boolean skipTx, GridCacheEntryEx entry, UUID subjId, String taskName, boolean deserializePortable, boolean skipVals)
protected boolean	isNearLocallyMapped(GridCacheEntryEx e, long topVer)
protected IgniteInternalFuture<Boolean>	lockAllAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx tx, boolean isInvalidate, boolean isRead, boolean retval, TransactionIsolation isolation, long accessTtl, CacheEntryPredicate[] filter)
void	onDeferredDelete(GridCacheEntryEx entry, GridCacheVersion ver)
void	removeLocks(GridCacheVersion ver, Collection<KeyCacheObject> keys) Removes locks regardless of whether they are owned or not for given version and keys.
void	start() Starts this cache.
GridNearTxRemote	startRemoteTx(UUID nodeId, GridDhtLockRequest req)
String	toString()
void	unlockAll(Collection<? extends K> keys, CacheEntryPredicate[] filter) Unlocks given keys only if current thread owns the locks.

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

clearLocally0, clearLocally0, entry, entryEx, entryEx, entryExx, entrySet, entrySet, evict, evictAll, evictNearOnly, igfsDataSpaceMax, igfsDataSpaceUsed, init, isAllLockedNearOnly, isIgfsDataCache, isLocked, isLockedNearOnly, isMongoDataCache, isMongoMetaCache, isNear, keySet, loadAsync, localLoad, localLoadCache, localLoadCacheAsync, nearEntries, nearEntriesIterator, nearKeySet, nearSize, offHeapAllocatedSize, offHeapEntriesCount, offHeapIterator, onIgfsDataSizeChanged, peek, peek, peekExx, peekNearOnly, preloader, primaryEntrySet, primaryKeySet, primarySize, primaryValues, processGetResponse, promote, promote, promoteAll, randomEntry, readThroughAllAsync, reload, size, splitClearLocally, swapIterator, swapKeys, swapSize, values

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

lockAllAsync, removeAll, removeAllAsync, removeVersionedEntry, txLockAsync

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

affinity, allEntries, asyncOp, asyncOpAcquire, asyncOpRelease, awaitLastFut, cache, checkJta, clear, clear, clear, clearAll, clearAsync, clearAsync, clearAsync, clearLocally, clearLocally, clearLocally, clearLocallyAll, commitTxAsync, configuration, containsKey, containsKeyAsync, containsKeys, containsKeysAsync, containsValue, context, entries, entryEx, entryEx, entryExSafe, entrySet, entrySetx, evict, evictAll, evictAll, expiry, expiryPolicy, flags, flagsOff, flagsOn, forceRepartition, forSubjectId, get, get, get, getAll, getAll, getAllAsync, getAllAsync, getAllAsync, getAllAsync0, getAllOutTx, getAllOutTxAsync, getAsync, getAsync, getForcePrimary, getForcePrimaryAsync, globalPrimarySize, globalSize, gridProjection, igniteIterator, invoke, invokeAll, invokeAll, invokeAllAsync, invokeAllAsync, invokeAsync, isColocated, isDht, isDhtAtomic, isEmpty, isLocal, isLockedByThread, iterator, iterator, keepPortable, keepPortable0, keySet, loadAll, localEntries, localPeek, localRemoveAll, localRemoveAll, localSize, lock, lockAll, lockAsync, log, map, metrics, metrics0, mxBean, name, onKernalStart, onKernalStop, onUndeploy, overflowSize, peek, peek0, peek0, peek0, peekAll0, peekEx, peekEx, predicate, primaryEntrySet, primaryEntrySetx, primaryKeySet, primaryValues, printMemoryStats, projection, projection, put, put, putAll, putAllAsync, putAllConflict, putAllConflictAsync, putAsync, putAsync, putIfAbsent, putIfAbsentAsync, putx, putx, putxAsync, putxAsync, putxIfAbsent, putxIfAbsentAsync, queries, readExternal, readResolve, reloadAllAsync0, reloadAsync, remove, remove, remove, removeAll, removeAllAsync, removeAllConflict, removeAllConflictAsync, removeAsync, removeAsync, removeAsync, removeEntry, removeIfObsolete, removex, removex, removex, removexAsync, removexAsync, removexAsync, replace, replace, replaceAsync, replaceAsync, replacex, replacex, replacexAsync, replacexAsync, saveFuture, size, sizeAsync, startInfo, stop, stopInfo, toMap, tx, txStart, txStart, txStart, txStartEx, txSynchronizations, txSynchronize, txUnsynchronize, unlock, validateCacheKey, validateCacheKeys, values, withExpiryPolicy, writeExternal

Methods inherited from class java.lang.Object

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

Constructor Detail

GridNearTransactionalCache

public GridNearTransactionalCache()

Empty constructor required for Externalizable.

GridNearTransactionalCache

public GridNearTransactionalCache(GridCacheContext<K,V> ctx)

Parameters:

ctx - Context.

Method Detail

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 GridCacheAdapter<K,V>

Throws:

IgniteCheckedException - If start failed.

dht

public void dht(GridDhtCache<K,V> dht)

Parameters:

dht - DHT cache.

dht

public GridDhtCache<K,V> dht()

Specified by:

dht in class GridNearCacheAdapter<K,V>

Returns:

DHT cache.

getAllAsync

public IgniteInternalFuture<Map<K,V>> getAllAsync(@Nullable
                                         Collection<? extends K> keys,
                                         boolean forcePrimary,
                                         boolean skipTx,
                                         @Nullable
                                         GridCacheEntryEx entry,
                                         @Nullable
                                         UUID subjId,
                                         String taskName,
                                         boolean deserializePortable,
                                         boolean skipVals)

Overrides:

getAllAsync in class GridCacheAdapter<K,V>

clearLocks

public void clearLocks(UUID nodeId,
              GridDhtUnlockRequest req)

Parameters:

nodeId - Node ID.

req - Request.

startRemoteTx

@Nullable
public GridNearTxRemote startRemoteTx(UUID nodeId,
                                      GridDhtLockRequest req)
                               throws IgniteCheckedException,
                                      GridDistributedLockCancelledException

Parameters:

nodeId - Primary node ID.

req - Request.

Returns:

Remote transaction.

Throws:

IgniteCheckedException - If failed.

GridDistributedLockCancelledException - If lock has been cancelled.

lockAllAsync

protected IgniteInternalFuture<Boolean> lockAllAsync(Collection<KeyCacheObject> keys,
                                         long timeout,
                                         IgniteTxLocalEx tx,
                                         boolean isInvalidate,
                                         boolean isRead,
                                         boolean retval,
                                         TransactionIsolation isolation,
                                         long accessTtl,
                                         CacheEntryPredicate[] filter)

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.

accessTtl - TTL for read operation.

filter - Optional filter.

Returns:

Future for locks.

isNearLocallyMapped

protected boolean isNearLocallyMapped(GridCacheEntryEx e,
                          long topVer)

Parameters:

e - Transaction entry.

topVer - Topology version.

Returns:

True if entry is locally mapped as a primary or back up node.

evictNearEntry

protected boolean evictNearEntry(GridCacheEntryEx e,
                     GridCacheVersion obsoleteVer,
                     long topVer)

Parameters:

e - Entry to evict if it qualifies for eviction.

obsoleteVer - Obsolete version.

topVer - Topology version.

Returns:

True if attempt was made to evict the entry.

unlockAll

public void unlockAll(Collection<? extends K> keys,
             CacheEntryPredicate[] filter)

Unlocks given keys only if current thread owns the locks. Only the keys that have been locked by calling thread and pass through the filter (if any) will be unlocked. If none of the key locks is owned by current thread, then this method will do nothing.

Transactions

Locks are not transactional and should not be used from within transactions. If you do need explicit locking within transaction, then you should use TransactionConcurrency.PESSIMISTIC concurrency control for transaction which will acquire explicit locks for relevant cache operations.

Cache Flags

This method is not available if any of the following flags are set on projection: CacheFlag.LOCAL, CacheFlag.READ.

Parameters:

keys - Keys to unlock.

filter - Optional filter which needs to pass for individual entries to be unlocked.

removeLocks

public void removeLocks(GridCacheVersion ver,
               Collection<KeyCacheObject> keys)

Removes locks regardless of whether they are owned or not for given version and keys.

Parameters:

ver - Lock version.

keys - Keys.

onDeferredDelete

public void onDeferredDelete(GridCacheEntryEx entry,
                    GridCacheVersion ver)

Specified by:

onDeferredDelete in class GridCacheAdapter<K,V>

Parameters:

entry - Entry.

ver - Version.

toString

public String toString()

Overrides:

toString in class GridNearCacheAdapter<K,V>