| Modifier and Type | Method and Description |
|---|---|
IgniteInternalTx |
IgniteTransactionsEx.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
IgniteInternalTx |
IgniteTransactionsEx.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize) |
| Constructor and Description |
|---|
GridAffinityAssignmentCache(GridCacheContext ctx,
String cacheName,
CacheAffinityFunction aff,
CacheAffinityKeyMapper affMapper,
int backups)
Constructs affinity cached calculations.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<K,V> |
GridCachePreloaderAdapter.cctx
Cache context.
|
protected GridCacheContext<K,V> |
GridCacheManagerAdapter.cctx
Context.
|
protected GridCacheContext<K,V> |
GridCacheMapEntry.cctx
Cache registry.
|
protected GridCacheContext<K,V> |
GridCacheClearAllRunnable.ctx
Cache context.
|
protected GridCacheContext<K,V> |
GridCacheConcurrentMap.ctx
Cache context.
|
protected GridCacheContext<K,V> |
GridCacheAdapter.ctx
Cache configuration.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheContext<K,V> |
GridCacheSharedContext.cacheContext(int cacheId)
Gets cache context by cache ID.
|
GridCacheContext<K,V> |
GridCacheProjectionEx.context() |
protected GridCacheContext<K,V> |
GridCacheManagerAdapter.context() |
GridCacheContext<K,V> |
GridCacheMapEntry.context() |
GridCacheContext<K,V> |
IgniteCacheProxy.context() |
GridCacheContext<K,V> |
GridCacheProjectionImpl.context()
Gets cache context.
|
GridCacheContext<K,V> |
GridCacheEntryEx.context() |
GridCacheContext |
GridCacheProxyImpl.context() |
GridCacheContext<K,V> |
GridCacheAdapter.context() |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCacheContext<K,V>> |
GridCacheSharedContext.cacheContexts()
Gets all cache contexts for local node.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheSharedContext.addCacheContext(GridCacheContext cacheCtx)
Adds cache context to shared cache context.
|
boolean |
GridCacheMvccManager.addNext(GridCacheContext<K,V> cacheCtx,
GridCacheMvccCandidate<K> cand) |
boolean |
GridCacheMvccManager.addRemoved(GridCacheContext<K,V> cacheCtx,
GridCacheVersion ver) |
static boolean |
GridCacheUtils.affinityNode(GridCacheContext ctx,
ClusterNode s)
Checks if given node has specified cache started and the local DHT storage is enabled.
|
static Collection<ClusterNode> |
GridCacheUtils.affinityNodes(GridCacheContext ctx)
Gets all nodes on which cache with the same name is started and the local DHT storage is enabled.
|
static Collection<ClusterNode> |
GridCacheUtils.affinityNodes(GridCacheContext ctx,
long topOrder)
Gets DHT affinity nodes.
|
static Collection<ClusterNode> |
GridCacheUtils.aliveNodes(GridCacheContext ctx,
long topOrder)
Gets alive nodes.
|
static Collection<ClusterNode> |
GridCacheUtils.aliveRemoteNodes(GridCacheContext ctx,
long topOrder)
Gets alive nodes.
|
static Collection<ClusterNode> |
GridCacheUtils.allNodes(GridCacheContext ctx)
Gets all nodes on which cache with the same name is started.
|
static Collection<ClusterNode> |
GridCacheUtils.allNodes(GridCacheContext ctx,
long topOrder)
Gets all nodes on which cache with the same name is started.
|
static <K,V> IgniteClosure<K,javax.cache.Cache.Entry<K,V>> |
GridCacheUtils.cacheKey2Entry(GridCacheContext<K,V> ctx)
Gets closure which returns
Entry given cache key. |
static boolean |
GridCacheUtils.cacheNode(GridCacheContext ctx,
ClusterNode node)
Checks if given node contains configured cache with the name
as described by given cache context.
|
static void |
GridCacheUtils.checkStore(GridCacheContext<?,?> ctx)
Checks that cache store is present.
|
GridCacheMapEntry<K,V> |
GridCacheMapEntryFactory.create(GridCacheContext<K,V> ctx,
long topVer,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
static boolean |
GridCacheUtils.isNearEnabled(GridCacheContext ctx)
Checks if near cache is enabled for cache context.
|
boolean |
GridCacheMvccManager.isRemoved(GridCacheContext<K,V> cacheCtx,
GridCacheVersion ver) |
static <K,V> IgnitePredicate<K> |
GridCacheUtils.keyHasMeta(GridCacheContext<K,V> ctx,
String meta) |
static <K> Map<ClusterNode,Collection<K>> |
GridCacheUtils.mapKeysToNodes(GridCacheContext<K,?> ctx,
Collection<? extends K> keys) |
static ClusterNode |
GridCacheUtils.oldest(GridCacheContext cctx)
Gets oldest alive node for specified topology version.
|
static ClusterNode |
GridCacheUtils.oldest(GridCacheContext cctx,
long topOrder)
Gets oldest alive node for specified topology version.
|
void |
GridCacheDeploymentManager.onUndeploy(ClassLoader ldr,
GridCacheContext<K,V> ctx)
Undeploys given class loader.
|
static <T> T |
GridCacheUtils.outTx(Callable<T> cmd,
GridCacheContext ctx)
Method executes any Callable out of scope of transaction.
|
static ClusterNode |
GridCacheUtils.primaryNode(GridCacheContext ctx,
Object key)
Gets primary node on which given key is cached.
|
static Collection<ClusterNode> |
GridCacheUtils.remoteNodes(GridCacheContext ctx)
Gets remote nodes on which cache with the same name is started.
|
static Collection<ClusterNode> |
GridCacheUtils.remoteNodes(GridCacheContext ctx,
long topOrder)
Gets remote nodes on which cache with the same name is started.
|
void |
GridCacheManagerAdapter.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
GridCacheManager.start(GridCacheContext<K,V> cctx)
Starts manager.
|
static String |
GridCacheUtils.swapSpaceName(GridCacheContext<?,?> ctx) |
boolean |
GridCacheSharedContext.txCompatible(IgniteInternalTx<K,V> tx,
Iterable<Integer> activeCacheIds,
GridCacheContext<K,V> cacheCtx) |
static IgniteInternalTx |
GridCacheUtils.txStartInternal(GridCacheContext ctx,
CacheProjection prj,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
void |
GridCacheEntryInfo.unmarshal(GridCacheContext<K,V> ctx,
ClassLoader clsLdr)
Unmarshalls entry.
|
protected void |
GridCacheMessage.unmarshalInfo(GridCacheEntryInfo<K,V> info,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.unmarshalInfos(Iterable<? extends GridCacheEntryInfo<K,V>> infos,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
void |
GridCacheEntryInfo.unmarshalValue(GridCacheContext<K,V> ctx,
ClassLoader ldr) |
void |
GridCacheDeploymentManager.unwind(GridCacheContext ctx)
Undeploy all queued up closures.
|
static void |
GridCacheUtils.unwindEvicts(GridCacheContext ctx) |
| Constructor and Description |
|---|
CacheInvokeEntry(GridCacheContext cctx,
K key,
V val) |
CacheMetricsImpl(GridCacheContext<?,?> cctx)
Creates cache metrics;
|
GridCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap<K,V> map) |
GridCacheAdapter(GridCacheContext<K,V> ctx,
int startSize) |
GridCacheConcurrentMap(GridCacheContext<K,V> ctx,
int initCap)
Creates a new, empty map with the specified initial capacity,
and with default load factor (0.75) and concurrencyLevel (16).
|
GridCacheConcurrentMap(GridCacheContext<K,V> ctx,
int initCap,
float loadFactor)
Creates a new, empty map with the specified initial capacity
and load factor and with the default concurrencyLevel (16).
|
GridCacheConcurrentMap(GridCacheContext<K,V> ctx,
int initCap,
float loadFactor,
int concurrencyLevel)
Creates a new, empty map with the specified initial
capacity, load factor and concurrency level.
|
GridCacheEntryInfoCollectSwapListener(IgniteLogger log,
GridCacheContext<K,V> ctx) |
GridCacheEntrySet(GridCacheContext<K,V> ctx,
Collection<? extends javax.cache.Cache.Entry<K,V>> c,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
GridCacheGateway(GridCacheContext<K,V> ctx) |
GridCacheIterator(GridCacheContext<K,V> cctx,
Iterable<? extends javax.cache.Cache.Entry<K,V>> c,
IgniteClosure<javax.cache.Cache.Entry<K,V>,T> trans,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
GridCacheKeySet(GridCacheContext<K,V> ctx,
Collection<? extends javax.cache.Cache.Entry<K,V>> c,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
GridCacheMapEntry(GridCacheContext<K,V> cctx,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
GridCacheMultiTxFuture(GridCacheContext<K,V> cctx) |
GridCacheMvcc(GridCacheContext<K,?> cctx) |
GridCachePreloaderAdapter(GridCacheContext<K,V> cctx) |
GridCacheProjectionImpl(CacheProjection<K,V> parent,
GridCacheContext<K,V> cctx,
IgniteBiPredicate<K,V> kvFilter,
IgnitePredicate<? super javax.cache.Cache.Entry<K,V>> entryFilter,
Set<CacheFlag> flags,
UUID subjId,
boolean keepPortable,
javax.cache.expiry.ExpiryPolicy expiryPlc) |
GridCacheProxyImpl(GridCacheContext<K,V> ctx,
GridCacheProjectionEx<K,V> delegate,
GridCacheProjectionImpl<K,V> prj) |
GridCacheValueCollection(GridCacheContext<K,V> ctx,
Collection<? extends javax.cache.Cache.Entry<K,V>> c,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteCacheProxy(GridCacheContext<K,V> ctx,
GridCacheProjectionEx<K,V> delegate,
GridCacheProjectionImpl<K,V> prj,
boolean async) |
| Constructor and Description |
|---|
GridCacheAffinityImpl(GridCacheContext<K,V> cctx) |
GridCacheAffinityProxy(GridCacheContext<K,V> cctx,
CacheAffinity<K> delegate) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedUnlockRequest.addKey(K key,
byte[] bytes,
GridCacheContext<K,V> ctx) |
void |
GridDistributedLockRequest.addKeyBytes(K key,
byte[] keyBytes,
boolean retVal,
Collection<GridCacheMvccCandidate<K>> cands,
GridCacheContext<K,V> ctx)
Adds a key.
|
void |
GridDistributedLockResponse.addValueBytes(V val,
byte[] valBytes,
GridCacheContext<K,V> ctx) |
GridTuple<V> |
GridDistributedTxRemoteAdapter.peek(GridCacheContext<K,V> cacheCtx,
boolean failFast,
K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Constructor and Description |
|---|
GridDistributedCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap<K,V> map) |
GridDistributedCacheAdapter(GridCacheContext<K,V> ctx,
int startSize) |
GridDistributedCacheEntry(GridCacheContext<K,V> ctx,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtLockRequest.addDhtKey(K key,
byte[] keyBytes,
boolean invalidateEntry,
GridCacheContext<K,V> ctx)
Adds a DHT key.
|
void |
GridDhtTxLocalAdapter.addInvalidPartition(GridCacheContext<K,V> ctx,
int part) |
void |
GridDhtTxRemote.addInvalidPartition(GridCacheContext<K,V> cacheCtx,
int part) |
void |
GridDhtTxRemote.addWrite(GridCacheContext<K,V> cacheCtx,
GridCacheOperation op,
IgniteTxKey<K> key,
byte[] keyBytes,
V val,
byte[] valBytes,
Collection<T2<javax.cache.processor.EntryProcessor<K,V,?>,Object[]>> entryProcessors,
long ttl) |
IgniteInternalFuture<GridNearLockResponse<K,V>> |
GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<K,V> cacheCtx,
ClusterNode nearNode,
GridNearLockRequest<K,V> req,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter0) |
protected boolean |
GridDhtTxLocal.updateNearCache(GridCacheContext<K,V> cacheCtx,
K key,
long topVer)
Checks whether near cache should be updated.
|
protected boolean |
GridDhtTxRemote.updateNearCache(GridCacheContext<K,V> cacheCtx,
K key,
long topVer)
Checks whether near cache should be updated.
|
| Constructor and Description |
|---|
GridDhtAssignmentFetchFuture(GridCacheContext<K,V> ctx,
long topVer,
Collection<ClusterNode> availableNodes) |
GridDhtCache(GridCacheContext<K,V> ctx) |
GridDhtCache(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap<K,V> map) |
GridDhtCacheAdapter(GridCacheContext<K,V> ctx) |
GridDhtCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap<K,V> map)
Constructor used for near-only cache.
|
GridDhtCacheEntry(GridCacheContext<K,V> ctx,
long topVer,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
GridDhtGetFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
LinkedHashMap<? extends K,Boolean> keys,
boolean readThrough,
boolean reload,
IgniteTxLocalEx<K,V> tx,
long topVer,
UUID subjId,
int taskNameHash,
boolean deserializePortable,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals) |
GridDhtLockFuture(GridCacheContext<K,V> cctx,
UUID nearNodeId,
GridCacheVersion nearLockVer,
long topVer,
int cnt,
boolean read,
long timeout,
GridDhtTxLocalAdapter<K,V> tx,
long threadId,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
GridDhtTransactionalCacheAdapter(GridCacheContext<K,V> ctx) |
GridDhtTransactionalCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap<K,V> map)
Constructor used for near-only cache.
|
GridNoStorageCacheMap(GridCacheContext<K,V> ctx) |
GridPartitionedGetFuture(GridCacheContext<K,V> cctx,
Collection<? extends K> keys,
long topVer,
boolean readThrough,
boolean reload,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializePortable,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals) |
| Constructor and Description |
|---|
GridDhtColocatedCache(GridCacheContext<K,V> ctx) |
GridDhtColocatedCache(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap<K,V> map)
Creates colocated cache with specified map.
|
GridDhtColocatedCacheEntry(GridCacheContext<K,V> ctx,
long topVer,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
GridDhtColocatedLockFuture(GridCacheContext<K,V> cctx,
Collection<? extends K> keys,
GridNearTxLocal<K,V> tx,
boolean read,
boolean retval,
long timeout,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
GridDhtDetachedCacheEntry(GridCacheContext<K,V> ctx,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
| Constructor and Description |
|---|
GridDhtForceKeysFuture(GridCacheContext<K,V> cctx,
long topVer,
Collection<? extends K> keys,
GridDhtPreloader<K,V> preloader) |
GridDhtPartitionDemandPool(GridCacheContext<K,V> cctx,
ReadWriteLock busyLock) |
GridDhtPreloader(GridCacheContext<K,V> cctx) |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
GridNearTxLocal.accessPolicy(GridCacheContext ctx,
IgniteTxKey<K> key,
javax.cache.expiry.ExpiryPolicy expiryPlc) |
boolean |
GridNearTxRemote.addEntry(GridCacheContext<K,V> cacheCtx,
IgniteTxKey<K> key,
byte[] keyBytes,
GridCacheOperation op,
V val,
byte[] valBytes,
GridCacheVersion drVer) |
void |
GridNearLockRequest.addKeyBytes(K key,
byte[] keyBytes,
boolean retVal,
GridCacheVersion dhtVer,
GridCacheContext<K,V> ctx)
Adds a key.
|
void |
GridNearLockResponse.addValueBytes(V val,
byte[] valBytes,
boolean filterPassed,
GridCacheVersion dhtVer,
GridCacheVersion mappedVer,
GridCacheContext<K,V> ctx) |
protected GridCacheEntryEx<K,V> |
GridNearTxLocal.entryEx(GridCacheContext<K,V> cacheCtx,
IgniteTxKey<K> key)
Gets cache entry for given key.
|
protected GridCacheEntryEx<K,V> |
GridNearTxLocal.entryEx(GridCacheContext<K,V> cacheCtx,
IgniteTxKey<K> key,
long topVer)
Gets cache entry for given key and topology version.
|
void |
GridNearLockRequest.filter(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridCacheContext<K,V> ctx) |
IgniteInternalFuture<Boolean> |
GridNearTxLocal.loadMissing(GridCacheContext<K,V> cacheCtx,
boolean readThrough,
boolean async,
Collection<? extends K> keys,
boolean deserializePortable,
boolean skipVals,
IgniteBiInClosure<K,V> c) |
IgniteInternalFuture<GridCacheReturn<V>> |
GridNearTxLocal.lockAllAsync(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
boolean implicit,
boolean read,
long accessTtl) |
| Constructor and Description |
|---|
GridNearAtomicCache(GridCacheContext<K,V> ctx) |
GridNearCacheAdapter(GridCacheContext<K,V> ctx) |
GridNearCacheEntry(GridCacheContext<K,V> ctx,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
GridNearGetFuture(GridCacheContext<K,V> cctx,
Collection<? extends K> keys,
boolean readThrough,
boolean reload,
boolean forcePrimary,
IgniteTxLocalEx<K,V> tx,
UUID subjId,
String taskName,
boolean deserializePortable,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals) |
GridNearLockFuture(GridCacheContext<K,V> cctx,
Collection<? extends K> keys,
GridNearTxLocal<K,V> tx,
boolean read,
boolean retval,
long timeout,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
GridNearTransactionalCache(GridCacheContext<K,V> ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsCacheDrManager.start(GridCacheContext<K,V> cctx)
Starts manager.
|
| Constructor and Description |
|---|
GridLocalCache(GridCacheContext<K,V> ctx) |
GridLocalCacheEntry(GridCacheContext<K,V> ctx,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
| Constructor and Description |
|---|
GridLocalAtomicCache(GridCacheContext<K,V> ctx) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<K,V> |
GridCacheQueryFutureAdapter.cctx
Cache context.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheContext<K,V> |
IgniteTxEntry.context() |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
IgniteTxLocalAdapter.accessPolicy(GridCacheContext ctx,
IgniteTxKey<K> key,
javax.cache.expiry.ExpiryPolicy expiryPlc) |
protected void |
IgniteTxLocalAdapter.addActiveCache(GridCacheContext<K,V> cacheCtx)
Adds cache to the list of active caches in transaction.
|
void |
IgniteTxAdapter.addInvalidPartition(GridCacheContext<K,V> cacheCtx,
int part) |
void |
IgniteInternalTx.addInvalidPartition(GridCacheContext<K,V> cacheCtx,
int part) |
IgniteTxEntry<K,V> |
IgniteTxEntry.cleanCopy(GridCacheContext<K,V> ctx) |
protected IgniteInternalFuture<Set<K>> |
IgniteTxLocalAdapter.enlistWrite(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean implicit,
Map<? extends K,? extends V> lookup,
Map<? extends K,javax.cache.processor.EntryProcessor<K,V,Object>> invokeMap,
Object[] invokeArgs,
boolean retval,
boolean lockOnly,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridCacheReturn<V> ret,
Collection<K> enlisted,
Map<? extends K,GridCacheDrInfo<V>> drPutMap,
Map<? extends K,GridCacheVersion> drRmvMap)
Internal routine for putAll(..)
|
protected GridCacheEntryEx<K,V> |
IgniteTxLocalAdapter.entryEx(GridCacheContext<K,V> cacheCtx,
IgniteTxKey<K> key)
Gets cache entry for given key.
|
protected GridCacheEntryEx<K,V> |
IgniteTxLocalAdapter.entryEx(GridCacheContext<K,V> cacheCtx,
IgniteTxKey<K> key,
long topVer)
Gets cache entry for given key and topology version.
|
IgniteInternalFuture<Map<K,V>> |
IgniteTxLocalEx.getAllAsync(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean deserializePortable,
boolean skipVals) |
IgniteInternalFuture<Map<K,V>> |
IgniteTxLocalAdapter.getAllAsync(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean deserializePortable,
boolean skipVals) |
IgniteInternalFuture<?> |
IgniteTxLocalEx.groupLockAsync(GridCacheContext<K,V> cacheCtx,
Collection<K> keys)
Performs keys locking for affinity-based group lock transactions.
|
IgniteInternalFuture<?> |
IgniteTxLocalAdapter.groupLockAsync(GridCacheContext<K,V> cacheCtx,
Collection<K> keys)
Performs keys locking for affinity-based group lock transactions.
|
<T> IgniteInternalFuture<GridCacheReturn<Map<K,javax.cache.processor.EntryProcessorResult<T>>>> |
IgniteTxLocalEx.invokeAsync(GridCacheContext<K,V> cacheCtx,
Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,Object>> map,
Object... invokeArgs) |
<T> IgniteInternalFuture<GridCacheReturn<Map<K,javax.cache.processor.EntryProcessorResult<T>>>> |
IgniteTxLocalAdapter.invokeAsync(GridCacheContext<K,V> cacheCtx,
Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,Object>> map,
Object... invokeArgs) |
IgniteInternalFuture<Boolean> |
IgniteTxLocalEx.loadMissing(GridCacheContext<K,V> cacheCtx,
boolean readThrough,
boolean async,
Collection<? extends K> keys,
boolean deserializePortable,
boolean skipVals,
IgniteBiInClosure<K,V> c) |
IgniteInternalFuture<Boolean> |
IgniteTxLocalAdapter.loadMissing(GridCacheContext<K,V> cacheCtx,
boolean readThrough,
boolean async,
Collection<? extends K> keys,
boolean deserializePortable,
boolean skipVals,
IgniteBiInClosure<K,V> c) |
GridTuple<V> |
IgniteInternalTx.peek(GridCacheContext<K,V> ctx,
boolean failFast,
K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
GridTuple<V> |
IgniteTxLocalAdapter.peek(GridCacheContext<K,V> cacheCtx,
boolean failFast,
K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
protected Set<K> |
IgniteTxLocalAdapter.postLockWrite(GridCacheContext<K,V> cacheCtx,
Iterable<? extends K> keys,
Set<K> failed,
GridCacheReturn ret,
boolean rmv,
boolean retval,
boolean read,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
boolean computeInvoke)
Post lock processing for put or remove.
|
IgniteInternalFuture<GridCacheReturn<V>> |
IgniteTxLocalEx.putAllAsync(GridCacheContext<K,V> cacheCtx,
Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<GridCacheReturn<V>> |
IgniteTxLocalAdapter.putAllAsync(GridCacheContext<K,V> cacheCtx,
Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<?> |
IgniteTxLocalEx.putAllDrAsync(GridCacheContext<K,V> cacheCtx,
Map<? extends K,GridCacheDrInfo<V>> drMap) |
IgniteInternalFuture<?> |
IgniteTxLocalAdapter.putAllDrAsync(GridCacheContext<K,V> cacheCtx,
Map<? extends K,GridCacheDrInfo<V>> drMap) |
IgniteInternalFuture<GridCacheReturn<V>> |
IgniteTxLocalEx.removeAllAsync(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean retval,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<GridCacheReturn<V>> |
IgniteTxLocalAdapter.removeAllAsync(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean retval,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<?> |
IgniteTxLocalEx.removeAllDrAsync(GridCacheContext<K,V> cacheCtx,
Map<? extends K,GridCacheVersion> drMap) |
IgniteInternalFuture<?> |
IgniteTxLocalAdapter.removeAllDrAsync(GridCacheContext<K,V> cacheCtx,
Map<? extends K,GridCacheVersion> drMap) |
IgniteInternalTx |
IgniteTransactionsImpl.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
IgniteInternalTx |
IgniteTransactionsImpl.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize) |
protected boolean |
IgniteTxAdapter.updateNearCache(GridCacheContext<K,V> cacheCtx,
K key,
long topVer)
Checks whether near cache should be updated.
|
| Constructor and Description |
|---|
IgniteTxEntry(GridCacheContext<K,V> ctx,
IgniteInternalTx<K,V> tx,
GridCacheOperation op,
V val,
javax.cache.processor.EntryProcessor<K,V,?> entryProcessor,
Object[] invokeArgs,
long ttl,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filters,
GridCacheVersion drVer)
This constructor is meant for local transactions.
|
IgniteTxEntry(GridCacheContext<K,V> ctx,
IgniteInternalTx<K,V> tx,
GridCacheOperation op,
V val,
long ttl,
long drExpireTime,
GridCacheEntryEx<K,V> entry,
GridCacheVersion drVer)
This constructor is meant for remote transactions.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<?,?> |
GridCacheQueueAdapter.cctx
Cache context.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridSetQueryPredicate.init(GridCacheContext ctx) |
void |
DataStructuresProcessor.removeQueue(String name,
GridCacheContext cctx) |
void |
DataStructuresProcessor.removeSet(String name,
GridCacheContext cctx) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 17 2015