| 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 |
CacheLazyEntry.cctx
Cache context.
|
protected GridCacheContext<?,?> |
GridCacheMapEntry.cctx
Cache registry.
|
protected GridCacheContext |
GridCacheManagerAdapter.cctx
Context.
|
protected GridCacheContext<K,V> |
GridCachePreloaderAdapter.cctx
Cache context.
|
protected GridCacheContext |
GridCacheConcurrentMap.ctx
Cache context.
|
protected GridCacheContext<K,V> |
GridCacheClearAllRunnable.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> |
GridCacheProjectionImpl.context()
Gets cache context.
|
GridCacheContext<K,V> |
IgniteCacheProxy.context() |
protected GridCacheContext<K,V> |
GridCacheManagerAdapter.context() |
GridCacheContext<K,V> |
GridCacheProjectionEx.context() |
GridCacheContext |
GridCacheProxyImpl.context() |
GridCacheContext<K,V> |
GridCacheAdapter.context() |
<K,V> GridCacheContext<K,V> |
GridCacheEntryEx.context() |
<K,V> GridCacheContext<K,V> |
GridCacheMapEntry.context() |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCacheContext> |
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.
|
void |
GridCacheReturn.addEntryProcessResult(GridCacheContext cctx,
KeyCacheObject key,
Object key0,
Object res,
Exception err) |
boolean |
GridCacheMvccManager.addNext(GridCacheContext cacheCtx,
GridCacheMvccCandidate cand) |
boolean |
GridCacheMvccManager.addRemoved(GridCacheContext 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 |
GridCacheMapEntryFactory.create(GridCacheContext ctx,
long topVer,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
long ttl,
int hdrId) |
void |
GridCacheReturn.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEvictionEntry.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicateAdapter.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntrySerializablePredicate.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicate.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicateContainsValue.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheInvokeDirectResult.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.finishUnmarshalCacheObjects(Collection<? extends CacheObject> col,
GridCacheContext ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.finishUnmarshalCacheObjects(List<? extends CacheObject> col,
GridCacheContext ctx,
ClassLoader ldr) |
static boolean |
GridCacheUtils.isNearEnabled(GridCacheContext ctx)
Checks if near cache is enabled for cache context.
|
boolean |
GridCacheMvccManager.isRemoved(GridCacheContext cacheCtx,
GridCacheVersion ver) |
static IgnitePredicate<KeyCacheObject> |
GridCacheUtils.keyHasMeta(GridCacheContext ctx,
UUID meta) |
static <K> Map<ClusterNode,Collection<K>> |
GridCacheUtils.mapKeysToNodes(GridCacheContext<K,?> ctx,
Collection<? extends K> keys) |
void |
GridCacheEntryInfo.marshal(GridCacheContext ctx) |
protected void |
GridCacheMessage.marshalInfo(GridCacheEntryInfo info,
GridCacheContext ctx) |
protected void |
GridCacheMessage.marshalInfos(Iterable<? extends GridCacheEntryInfo> infos,
GridCacheContext ctx) |
int |
GridCacheEntryInfo.marshalledSize(GridCacheContext ctx) |
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.
|
void |
GridCacheReturn.prepareMarshal(GridCacheContext ctx) |
void |
CacheEvictionEntry.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicateAdapter.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntrySerializablePredicate.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicate.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicateContainsValue.prepareMarshal(GridCacheContext ctx) |
void |
CacheInvokeDirectResult.prepareMarshal(GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareMarshalCacheObjects(Collection<? extends CacheObject> col,
GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareMarshalCacheObjects(List<? extends CacheObject> col,
GridCacheContext ctx) |
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.
|
GridCacheReturn |
GridCacheReturn.set(GridCacheContext cctx,
CacheObject cacheObj,
boolean success) |
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 tx,
Iterable<Integer> activeCacheIds,
GridCacheContext<K,V> cacheCtx) |
static IgniteInternalTx |
GridCacheUtils.txStartInternal(GridCacheContext ctx,
CacheProjection prj,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
void |
GridCacheEntryInfo.unmarshal(GridCacheContext ctx,
ClassLoader clsLdr)
Unmarshalls entry.
|
protected void |
GridCacheMessage.unmarshalInfo(GridCacheEntryInfo info,
GridCacheContext ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.unmarshalInfos(Iterable<? extends GridCacheEntryInfo> infos,
GridCacheContext ctx,
ClassLoader ldr) |
void |
GridCacheEntryInfo.unmarshalValue(GridCacheContext<?,?> ctx,
ClassLoader ldr) |
void |
GridCacheDeploymentManager.unwind(GridCacheContext ctx)
Undeploy all queued up closures.
|
static void |
GridCacheUtils.unwindEvicts(GridCacheContext ctx) |
static <T> T |
GridCacheUtils.value(CacheObject cacheObj,
GridCacheContext ctx,
boolean cpy) |
GridCacheReturn |
GridCacheReturn.value(GridCacheContext cctx,
CacheObject v) |
| Constructor and Description |
|---|
CacheInvokeEntry(GridCacheContext<K,V> ctx,
KeyCacheObject keyObj,
K key,
CacheObject valObj,
V val) |
CacheInvokeEntry(GridCacheContext cctx,
KeyCacheObject keyObj,
CacheObject valObj) |
CacheLazyEntry(GridCacheContext<K,V> ctx,
KeyCacheObject keyObject,
K key,
CacheObject valObj,
V val) |
CacheLazyEntry(GridCacheContext cctx,
KeyCacheObject keyObj,
CacheObject valObj) |
CacheLazyEntry(GridCacheContext cctx,
KeyCacheObject keyObj,
V val) |
CacheMetricsImpl(GridCacheContext<?,?> cctx)
Creates cache metrics;
|
GridCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap map) |
GridCacheAdapter(GridCacheContext<K,V> ctx,
int startSize) |
GridCacheConcurrentMap(GridCacheContext 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 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 ctx,
int initCap,
float loadFactor,
int concurrencyLevel)
Creates a new, empty map with the specified initial
capacity, load factor and concurrency level.
|
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<?,?> cctx,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
long ttl,
int hdrId) |
GridCacheMultiTxFuture(GridCacheContext<K,V> cctx) |
GridCacheMvcc(GridCacheContext<?,?> cctx) |
GridCachePreloaderAdapter(GridCacheContext<K,V> cctx) |
GridCacheProjectionImpl(CacheProjection<K,V> parent,
GridCacheContext<K,V> cctx,
CacheEntryPredicate 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) |
GridCacheReturn(GridCacheContext cctx,
boolean loc,
Object v,
boolean success) |
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(KeyCacheObject key,
GridCacheContext ctx) |
void |
GridDistributedLockRequest.addKeyBytes(KeyCacheObject key,
boolean retVal,
Collection<GridCacheMvccCandidate> cands,
GridCacheContext ctx)
Adds a key.
|
<K,V> GridTuple<CacheObject> |
GridDistributedTxRemoteAdapter.peek(GridCacheContext cacheCtx,
boolean failFast,
KeyCacheObject key,
CacheEntryPredicate[] filter) |
| Constructor and Description |
|---|
GridDistributedCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap map) |
GridDistributedCacheAdapter(GridCacheContext<K,V> ctx,
int startSize) |
GridDistributedCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
long ttl,
int hdrId) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtLockRequest.addDhtKey(KeyCacheObject key,
boolean invalidateEntry,
GridCacheContext ctx)
Adds a DHT key.
|
void |
GridDhtTxRemote.addInvalidPartition(GridCacheContext cacheCtx,
int part) |
void |
GridDhtTxLocalAdapter.addInvalidPartition(GridCacheContext ctx,
int part) |
void |
GridDhtTxRemote.addWrite(GridCacheContext cacheCtx,
GridCacheOperation op,
IgniteTxKey key,
CacheObject val,
Collection<T2<javax.cache.processor.EntryProcessor<Object,Object,Object>,Object[]>> entryProcessors,
long ttl) |
IgniteInternalFuture<GridNearLockResponse> |
GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<K,V> cacheCtx,
ClusterNode nearNode,
GridNearLockRequest req,
CacheEntryPredicate[] filter0) |
protected boolean |
GridDhtTxLocal.updateNearCache(GridCacheContext cacheCtx,
KeyCacheObject key,
long topVer)
Checks whether near cache should be updated.
|
protected boolean |
GridDhtTxRemote.updateNearCache(GridCacheContext cacheCtx,
KeyCacheObject key,
long topVer)
Checks whether near cache should be updated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearAtomicUpdateResponse.addFailedKeys(Collection<Object> keys,
Throwable e,
GridCacheContext ctx)
Adds keys to collection of failed keys.
|
| Constructor and Description |
|---|
GridDhtColocatedCache(GridCacheContext<K,V> ctx) |
GridDhtColocatedCache(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap map)
Creates colocated cache with specified map.
|
GridDhtColocatedCacheEntry(GridCacheContext ctx,
long topVer,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
long ttl,
int hdrId) |
GridDhtColocatedLockFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
GridNearTxLocal tx,
boolean read,
boolean retval,
long timeout,
long accessTtl,
CacheEntryPredicate[] filter) |
GridDhtDetachedCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
long ttl,
int hdrId) |
| Constructor and Description |
|---|
GridDhtForceKeysFuture(GridCacheContext<K,V> cctx,
long topVer,
Collection<KeyCacheObject> 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 key,
javax.cache.expiry.ExpiryPolicy expiryPlc) |
boolean |
GridNearTxRemote.addEntry(GridCacheContext cacheCtx,
IgniteTxKey key,
GridCacheOperation op,
CacheObject val,
GridCacheVersion drVer) |
void |
GridNearLockRequest.addKeyBytes(KeyCacheObject key,
boolean retVal,
GridCacheVersion dhtVer,
GridCacheContext ctx)
Adds a key.
|
protected GridCacheEntryEx |
GridNearTxLocal.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key)
Gets cache entry for given key.
|
protected GridCacheEntryEx |
GridNearTxLocal.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key,
long topVer)
Gets cache entry for given key and topology version.
|
void |
GridNearLockRequest.filter(CacheEntryPredicate[] filter,
GridCacheContext ctx) |
void |
CacheVersionedValue.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr)
This method is called after the whole message is received
and is responsible for unmarshalling state.
|
IgniteInternalFuture<Boolean> |
GridNearTxLocal.loadMissing(GridCacheContext cacheCtx,
boolean readThrough,
boolean async,
Collection<KeyCacheObject> keys,
boolean deserializePortable,
boolean skipVals,
IgniteBiInClosure<KeyCacheObject,Object> c) |
<K> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.lockAllAsync(GridCacheContext 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 ctx,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
long ttl,
int hdrId) |
GridNearGetFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean reload,
boolean forcePrimary,
IgniteTxLocalEx tx,
UUID subjId,
String taskName,
boolean deserializePortable,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals) |
GridNearLockFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
GridNearTxLocal tx,
boolean read,
boolean retval,
long timeout,
long accessTtl,
CacheEntryPredicate[] filter) |
GridNearTransactionalCache(GridCacheContext<K,V> ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsCacheDrManager.start(GridCacheContext cctx)
Starts manager.
|
| Constructor and Description |
|---|
GridLocalCache(GridCacheContext<K,V> ctx) |
GridLocalCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry 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<?,?> |
IgniteTxEntry.context() |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
IgniteTxLocalAdapter.accessPolicy(GridCacheContext ctx,
IgniteTxKey key,
javax.cache.expiry.ExpiryPolicy expiryPlc) |
protected void |
IgniteTxLocalAdapter.addActiveCache(GridCacheContext cacheCtx)
Adds cache to the list of active caches in transaction.
|
void |
IgniteTxAdapter.addInvalidPartition(GridCacheContext<?,?> cacheCtx,
int part) |
void |
IgniteInternalTx.addInvalidPartition(GridCacheContext<?,?> cacheCtx,
int part) |
IgniteTxEntry |
IgniteTxEntry.cleanCopy(GridCacheContext<?,?> ctx) |
protected <K,V> IgniteInternalFuture<Set<KeyCacheObject>> |
IgniteTxLocalAdapter.enlistWrite(GridCacheContext cacheCtx,
Collection<?> keys,
GridCacheEntryEx cached,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean implicit,
Map<?,?> lookup,
Map<?,javax.cache.processor.EntryProcessor<K,V,Object>> invokeMap,
Object[] invokeArgs,
boolean retval,
boolean lockOnly,
CacheEntryPredicate[] filter,
GridCacheReturn ret,
Collection<KeyCacheObject> enlisted,
Map<KeyCacheObject,GridCacheDrInfo> drPutMap,
Map<KeyCacheObject,GridCacheVersion> drRmvMap)
Internal routine for putAll(..)
|
protected GridCacheEntryEx |
IgniteTxLocalAdapter.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key)
Gets cache entry for given key.
|
protected GridCacheEntryEx |
IgniteTxLocalAdapter.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key,
long topVer)
Gets cache entry for given key and topology version.
|
void |
IgniteTxKey.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
<K,V> IgniteInternalFuture<Map<K,V>> |
IgniteTxLocalEx.getAllAsync(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys,
GridCacheEntryEx cached,
boolean deserializePortable,
boolean skipVals,
boolean keepCacheObjects) |
<K,V> IgniteInternalFuture<Map<K,V>> |
IgniteTxLocalAdapter.getAllAsync(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys,
GridCacheEntryEx cached,
boolean deserializePortable,
boolean skipVals,
boolean keepCacheObjects) |
<K> IgniteInternalFuture<?> |
IgniteTxLocalEx.groupLockAsync(GridCacheContext cacheCtx,
Collection<K> keys)
Performs keys locking for affinity-based group lock transactions.
|
<K> IgniteInternalFuture<?> |
IgniteTxLocalAdapter.groupLockAsync(GridCacheContext cacheCtx,
Collection<K> keys)
Performs keys locking for affinity-based group lock transactions.
|
<K,V,T> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.invokeAsync(GridCacheContext cacheCtx,
Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,Object>> map,
Object... invokeArgs) |
<K,V,T> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.invokeAsync(GridCacheContext cacheCtx,
Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,Object>> map,
Object... invokeArgs) |
IgniteInternalFuture<Boolean> |
IgniteTxLocalEx.loadMissing(GridCacheContext cacheCtx,
boolean readThrough,
boolean async,
Collection<KeyCacheObject> keys,
boolean deserializePortable,
boolean skipVals,
IgniteBiInClosure<KeyCacheObject,Object> c) |
IgniteInternalFuture<Boolean> |
IgniteTxLocalAdapter.loadMissing(GridCacheContext cacheCtx,
boolean readThrough,
boolean async,
Collection<KeyCacheObject> keys,
boolean deserializePortable,
boolean skipVals,
IgniteBiInClosure<KeyCacheObject,Object> c) |
void |
TxEntryValueHolder.marshal(GridCacheSharedContext<?,?> sharedCtx,
GridCacheContext<?,?> ctx) |
IgniteTxLocalAdapter |
IgniteTxManager.newTx(boolean implicit,
boolean implicitSingle,
GridCacheContext sysCacheCtx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock) |
<T extends IgniteInternalTx> |
IgniteTxManager.onCreated(GridCacheContext cacheCtx,
T tx) |
<K,V> GridTuple<CacheObject> |
IgniteTxLocalAdapter.peek(GridCacheContext cacheCtx,
boolean failFast,
KeyCacheObject key,
CacheEntryPredicate[] filter) |
<K,V> GridTuple<CacheObject> |
IgniteInternalTx.peek(GridCacheContext ctx,
boolean failFast,
KeyCacheObject key,
CacheEntryPredicate[] filter) |
protected Set<KeyCacheObject> |
IgniteTxLocalAdapter.postLockWrite(GridCacheContext cacheCtx,
Iterable<KeyCacheObject> keys,
Set<KeyCacheObject> failed,
GridCacheReturn ret,
boolean rmv,
boolean retval,
boolean read,
long accessTtl,
CacheEntryPredicate[] filter,
boolean computeInvoke)
Post lock processing for put or remove.
|
void |
IgniteTxKey.prepareMarshal(GridCacheContext ctx) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.putAllAsync(GridCacheContext cacheCtx,
Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate[] filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.putAllAsync(GridCacheContext cacheCtx,
Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<?> |
IgniteTxLocalEx.putAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheDrInfo> drMap) |
IgniteInternalFuture<?> |
IgniteTxLocalAdapter.putAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheDrInfo> drMap) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.removeAllAsync(GridCacheContext cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx cached,
boolean retval,
CacheEntryPredicate[] filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.removeAllAsync(GridCacheContext cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx cached,
boolean retval,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<?> |
IgniteTxLocalEx.removeAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheVersion> drMap) |
IgniteInternalFuture<?> |
IgniteTxLocalAdapter.removeAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheVersion> drMap) |
<T> T |
IgniteTxManager.threadLocalTx(GridCacheContext cctx) |
IgniteInternalTx |
IgniteTransactionsImpl.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
IgniteInternalTx |
IgniteTransactionsImpl.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize) |
void |
TxEntryValueHolder.unmarshal(GridCacheContext<?,?> ctx,
ClassLoader ldr) |
protected boolean |
IgniteTxAdapter.updateNearCache(GridCacheContext<?,?> cacheCtx,
KeyCacheObject key,
long topVer)
Checks whether near cache should be updated.
|
IgniteInternalTx |
IgniteTxManager.userTx(GridCacheContext cctx) |
| Constructor and Description |
|---|
IgniteTxEntry(GridCacheContext<?,?> ctx,
IgniteInternalTx tx,
GridCacheOperation op,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
Object[] invokeArgs,
long ttl,
GridCacheEntryEx entry,
CacheEntryPredicate[] filters,
GridCacheVersion conflictVer)
This constructor is meant for local transactions.
|
IgniteTxEntry(GridCacheContext<?,?> ctx,
IgniteInternalTx tx,
GridCacheOperation op,
CacheObject val,
long ttl,
long conflictExpireTime,
GridCacheEntryEx entry,
GridCacheVersion conflictVer)
This constructor is meant for remote transactions.
|
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
IgniteCacheObjectProcessorImpl.prepareForCache(CacheObject obj,
GridCacheContext cctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
IgniteCacheObjectProcessor.prepareForCache(CacheObject obj,
GridCacheContext cctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
IgniteCacheObjectProcessorImpl.toCacheObject(GridCacheContext ctx,
long valPtr,
boolean tmp) |
CacheObject |
IgniteCacheObjectProcessor.toCacheObject(GridCacheContext ctx,
long valPtr,
boolean tmp) |
Object |
IgniteCacheObjectProcessorImpl.unwrapTemporary(GridCacheContext ctx,
Object obj)
Converts temporary off-heap object to heap-based.
|
Object |
IgniteCacheObjectProcessor.unwrapTemporary(GridCacheContext ctx,
Object obj)
Converts temporary off-heap object to heap-based.
|
| Modifier and Type | Method and Description |
|---|---|
<K,V> Map.Entry<K,V> |
DataStreamerEntry.toEntry(GridCacheContext ctx) |
| 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-RC3 Release Date : March 24 2015