| 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) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<?,?> |
GridCachePreloaderAdapter.cctx
Cache context.
|
protected GridCacheContext<?,?> |
GridCacheMapEntry.cctx
Cache registry.
|
protected GridCacheContext |
GridCacheManagerAdapter.cctx
Context.
|
protected GridCacheContext |
CacheLazyEntry.cctx
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> |
GridCacheProxyImpl.context() |
GridCacheContext<K,V> |
IgniteCacheProxy.context() |
protected GridCacheContext<K,V> |
GridCacheManagerAdapter.context() |
GridCacheContext<K,V> |
IgniteInternalCache.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 keepBinary) |
boolean |
GridCacheMvccManager.addNext(GridCacheContext cacheCtx,
GridCacheMvccCandidate cand) |
boolean |
GridCacheMvccManager.addRemoved(GridCacheContext cacheCtx,
GridCacheVersion ver) |
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,
AffinityTopologyVersion topOrder)
Gets DHT affinity nodes.
|
static Collection<ClusterNode> |
GridCacheUtils.allNodes(GridCacheContext ctx,
AffinityTopologyVersion topOrder)
Gets all nodes on which cache with the same name is started.
|
static void |
GridCacheUtils.checkStore(GridCacheContext<?,?> ctx)
Checks that cache store is present.
|
boolean |
GridCacheSharedContext.closed(GridCacheContext ctx)
Checks if cache context is closed.
|
GridCacheMapEntry |
GridCacheMapEntryFactory.create(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
void |
CacheEntryPredicate.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
GridCacheReturn.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicateContainsValue.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicateAdapter.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEvictionEntry.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntrySerializablePredicate.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,
int meta) |
void |
GridCacheEntryInfo.marshal(GridCacheContext ctx) |
static byte[] |
GridCacheUtils.marshal(GridCacheContext ctx,
Object obj) |
protected List<byte[]> |
GridCacheMessage.marshalCollection(Collection<?> col,
GridCacheContext ctx) |
protected void |
GridCacheMessage.marshalInfo(GridCacheEntryInfo info,
GridCacheContext ctx) |
protected void |
GridCacheMessage.marshalInfos(Iterable<? extends GridCacheEntryInfo> infos,
GridCacheContext ctx) |
protected byte[][] |
GridCacheMessage.marshalInvokeArguments(Object[] args,
GridCacheContext ctx) |
int |
GridCacheEntryInfo.marshalledSize(GridCacheContext ctx) |
void |
CacheAffinitySharedManager.onCacheCreated(GridCacheContext cctx) |
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 |
CacheEntryPredicate.prepareMarshal(GridCacheContext ctx) |
void |
GridCacheReturn.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicateContainsValue.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicateAdapter.prepareMarshal(GridCacheContext ctx) |
void |
CacheEvictionEntry.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntrySerializablePredicate.prepareMarshal(GridCacheContext ctx) |
void |
CacheInvokeDirectResult.prepareMarshal(GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareMarshalCacheObject(CacheObject obj,
GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareMarshalCacheObjects(Collection<? extends CacheObject> col,
GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareMarshalCacheObjects(List<? extends CacheObject> col,
GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareObject(Object o,
GridCacheContext ctx) |
void |
GridCacheSharedContext.removeCacheContext(GridCacheContext cacheCtx) |
GridCacheReturn |
GridCacheReturn.set(GridCacheContext cctx,
CacheObject cacheObj,
boolean success,
boolean keepBinary) |
void |
CacheOsConflictResolutionManager.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
GridCacheManagerAdapter.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
GridCacheManager.start(GridCacheContext<K,V> cctx)
Starts manager.
|
static String |
GridCacheUtils.swapSpaceName(GridCacheContext<?,?> ctx) |
static TransactionConfiguration |
GridCacheUtils.transactionConfiguration(GridCacheContext sysCacheCtx,
IgniteConfiguration cfg) |
static IgniteInternalTx |
GridCacheUtils.txStartInternal(GridCacheContext ctx,
IgniteInternalCache 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,
boolean keepBinary) |
String |
GridCacheSharedContext.verifyTxCompatibility(IgniteInternalTx tx,
GridLongList activeCacheIds,
GridCacheContext<K,V> cacheCtx) |
| Constructor and Description |
|---|
GridCacheAffinityImpl(GridCacheContext<K,V> cctx) |
GridCacheAffinityProxy(GridCacheContext<K,V> cctx,
Affinity<K> delegate) |
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
CacheObjectBinaryProcessorImpl.toCacheKeyObject(CacheObjectContext ctx,
GridCacheContext cctx,
Object obj,
boolean userObj) |
CacheObject |
CacheObjectBinaryProcessorImpl.toCacheObject(GridCacheContext ctx,
long valPtr,
boolean tmp) |
Object |
CacheObjectBinaryProcessorImpl.unwrapTemporary(GridCacheContext ctx,
Object obj)
Converts temporary off-heap object to heap-based.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedUnlockRequest.addKey(KeyCacheObject key,
GridCacheContext ctx) |
void |
GridDistributedLockRequest.addKeyBytes(KeyCacheObject key,
boolean retVal,
GridCacheContext ctx)
Adds a key.
|
GridTuple<CacheObject> |
GridDistributedTxRemoteAdapter.peek(GridCacheContext cacheCtx,
boolean failFast,
KeyCacheObject key) |
| 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) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<K,V> |
CacheDistributedGetFutureAdapter.cctx
Context.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtLockRequest.addDhtKey(KeyCacheObject key,
boolean invalidateEntry,
GridCacheContext ctx)
Adds a DHT key.
|
void |
GridDhtTxLocalAdapter.addInvalidPartition(GridCacheContext ctx,
int part) |
void |
GridDhtTxRemote.addInvalidPartition(GridCacheContext cacheCtx,
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,
boolean skipStore,
boolean keepBinary) |
IgniteInternalFuture<GridNearLockResponse> |
GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<?,?> cacheCtx,
ClusterNode nearNode,
GridNearLockRequest req,
CacheEntryPredicate[] filter0) |
protected boolean |
GridDhtTxLocal.updateNearCache(GridCacheContext cacheCtx,
KeyCacheObject key,
AffinityTopologyVersion topVer)
Checks whether near cache should be updated.
|
protected boolean |
GridDhtTxRemote.updateNearCache(GridCacheContext cacheCtx,
KeyCacheObject key,
AffinityTopologyVersion topVer)
Checks whether near cache should be updated.
|
Throwable |
GridDhtTopologyFuture.validateCache(GridCacheContext cctx)
Returns error is cache topology is not valid.
|
| Constructor and Description |
|---|
CacheDistributedGetFutureAdapter(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean canRemap,
boolean needVer,
boolean keepCacheObjects) |
GridCachePartitionedConcurrentMap(GridCacheContext ctx)
Constructor.
|
GridDhtCache(GridCacheContext<K,V> ctx) |
GridDhtCache(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap map) |
GridDhtCacheAdapter(GridCacheContext<K,V> ctx) |
GridDhtCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap map)
Constructor used for near-only cache.
|
GridDhtCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
GridDhtGetFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals) |
GridDhtGetSingleFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
KeyCacheObject key,
Boolean addRdr,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals) |
GridDhtLockFuture(GridCacheContext<?,?> cctx,
UUID nearNodeId,
GridCacheVersion nearLockVer,
AffinityTopologyVersion topVer,
int cnt,
boolean read,
boolean needReturnVal,
long timeout,
GridDhtTxLocalAdapter tx,
long threadId,
long createTtl,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore,
boolean keepBinary) |
GridDhtOffHeapCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
GridDhtPartitionsReservation(AffinityTopologyVersion topVer,
GridCacheContext<?,?> cctx,
Object appKey) |
GridDhtTransactionalCacheAdapter(GridCacheContext<K,V> ctx) |
GridDhtTransactionalCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap map)
Constructor used for near-only cache.
|
GridPartitionedGetFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean canRemap,
boolean needVer,
boolean keepCacheObjects) |
GridPartitionedSingleGetFuture(GridCacheContext cctx,
KeyCacheObject key,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean canRemap,
boolean needVer,
boolean keepCacheObjects) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext |
GridNearAtomicAbstractUpdateFuture.cctx
Cache context.
|
protected GridCacheContext |
GridDhtAtomicAbstractUpdateFuture.cctx
Cache context.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearAtomicUpdateResponse.addFailedKeys(Collection<KeyCacheObject> 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,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
GridDhtColocatedLockFuture(GridCacheContext<?,?> cctx,
Collection<KeyCacheObject> keys,
GridNearTxLocal tx,
boolean read,
boolean retval,
long timeout,
long createTtl,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore,
boolean keepBinary) |
GridDhtColocatedOffHeapCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
GridDhtDetachedCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
int hdrId) |
| Modifier and Type | Method and Description |
|---|---|
Throwable |
GridDhtPartitionsExchangeFuture.validateCache(GridCacheContext cctx)
Returns error is cache topology is not valid.
|
| Constructor and Description |
|---|
GridDhtForceKeysFuture(GridCacheContext<K,V> cctx,
AffinityTopologyVersion topVer,
Collection<KeyCacheObject> keys,
GridDhtPreloader preloader) |
GridDhtPartitionDemander(GridCacheContext<?,?> cctx,
ReadWriteLock demandLock) |
GridDhtPreloader(GridCacheContext<?,?> cctx) |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
GridNearTxLocal.accessPolicy(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys) |
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,
boolean skipStore,
boolean keepBinary) |
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,
AffinityTopologyVersion 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<Void> |
GridNearTxLocal.loadMissing(GridCacheContext cacheCtx,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean async,
Collection<KeyCacheObject> keys,
boolean skipVals,
boolean needVer,
boolean keepBinary,
javax.cache.expiry.ExpiryPolicy expiryPlc,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> c) |
<K> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.lockAllAsync(GridCacheContext cacheCtx,
Collection<? extends K> keys,
boolean retval,
boolean read,
long createTtl,
long accessTtl,
boolean skipStore,
boolean keepBinary) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsCacheDrManager.start(GridCacheContext cctx)
Starts manager.
|
| Constructor and Description |
|---|
GridLocalCache(GridCacheContext<K,V> ctx) |
| 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() |
GridCacheContext |
IgniteTxImplicitSingleStateImpl.singleCacheContext(GridCacheSharedContext cctx) |
GridCacheContext |
IgniteTxStateImpl.singleCacheContext(GridCacheSharedContext cctx) |
GridCacheContext |
IgniteTxRemoteStateAdapter.singleCacheContext(GridCacheSharedContext cctx) |
GridCacheContext |
IgniteTxState.singleCacheContext(GridCacheSharedContext cctx) |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
IgniteTxLocalAdapter.accessPolicy(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys) |
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 |
IgniteTxImplicitSingleStateImpl.addActiveCache(GridCacheContext ctx,
IgniteTxLocalAdapter tx) |
void |
IgniteTxStateImpl.addActiveCache(GridCacheContext cacheCtx,
IgniteTxLocalAdapter tx) |
void |
IgniteTxRemoteStateAdapter.addActiveCache(GridCacheContext cacheCtx,
IgniteTxLocalAdapter tx) |
void |
IgniteTxState.addActiveCache(GridCacheContext cacheCtx,
IgniteTxLocalAdapter tx) |
void |
IgniteTxAdapter.addInvalidPartition(GridCacheContext<?,?> cacheCtx,
int part) |
void |
IgniteInternalTx.addInvalidPartition(GridCacheContext<?,?> cacheCtx,
int part) |
IgniteTxEntry |
IgniteTxEntry.cleanCopy(GridCacheContext<?,?> ctx) |
protected GridCacheEntryEx |
IgniteTxLocalAdapter.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key)
Gets cache entry for given key.
|
protected GridCacheEntryEx |
IgniteTxLocalAdapter.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key,
AffinityTopologyVersion topVer)
Gets cache entry for given key and topology version.
|
void |
IgniteTxKey.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
<K,V> IgniteInternalFuture<Map<K,V>> |
IgniteTxLocalAdapter.getAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Collection<KeyCacheObject> keys,
boolean deserializeBinary,
boolean skipVals,
boolean keepCacheObjects,
boolean skipStore,
boolean needVer) |
<K,V> IgniteInternalFuture<Map<K,V>> |
IgniteTxLocalEx.getAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Collection<KeyCacheObject> keys,
boolean deserializeBinary,
boolean skipVals,
boolean keepCacheObjects,
boolean skipStore,
boolean needVer) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.invokeAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
K key,
javax.cache.processor.EntryProcessor<K,V,Object> entryProcessor,
Object... invokeArgs) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.invokeAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
K key,
javax.cache.processor.EntryProcessor<K,V,Object> entryProcessor,
Object... invokeArgs) |
<K,V,T> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.invokeAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,Object>> map,
Object... invokeArgs) |
<K,V,T> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.invokeAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,Object>> map,
Object... invokeArgs) |
IgniteInternalFuture<Void> |
IgniteTxLocalAdapter.loadMissing(GridCacheContext cacheCtx,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean async,
Collection<KeyCacheObject> keys,
boolean skipVals,
boolean needVer,
boolean keepBinary,
javax.cache.expiry.ExpiryPolicy expiryPlc,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> c) |
IgniteInternalFuture<Void> |
IgniteTxLocalEx.loadMissing(GridCacheContext cacheCtx,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean async,
Collection<KeyCacheObject> keys,
boolean skipVals,
boolean needVer,
boolean keepBinary,
javax.cache.expiry.ExpiryPolicy expiryPlc,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> c) |
void |
TxEntryValueHolder.marshal(GridCacheContext<?,?> ctx) |
IgniteTxLocalAdapter |
IgniteTxManager.newTx(boolean implicit,
boolean implicitSingle,
GridCacheContext sysCacheCtx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean storeEnabled,
int txSize) |
<T extends IgniteInternalTx> |
IgniteTxManager.onCreated(GridCacheContext cacheCtx,
T tx) |
protected void |
IgniteTxLocalStateAdapter.onTxEnd(GridCacheContext cacheCtx,
IgniteInternalTx tx,
boolean commit) |
GridTuple<CacheObject> |
IgniteTxLocalAdapter.peek(GridCacheContext cacheCtx,
boolean failFast,
KeyCacheObject key) |
GridTuple<CacheObject> |
IgniteInternalTx.peek(GridCacheContext ctx,
boolean failFast,
KeyCacheObject key) |
protected void |
IgniteTxLocalAdapter.postLockWrite(GridCacheContext cacheCtx,
Iterable<KeyCacheObject> keys,
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> |
IgniteTxLocalAdapter.putAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Map<? extends K,? extends V> map,
boolean retval) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.putAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Map<? extends K,? extends V> map,
boolean retval) |
IgniteInternalFuture<?> |
IgniteTxLocalAdapter.putAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheDrInfo> drMap) |
IgniteInternalFuture<?> |
IgniteTxLocalEx.putAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheDrInfo> drMap) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.putAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
K key,
V val,
boolean retval,
CacheEntryPredicate filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.putAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
K key,
V val,
boolean retval,
CacheEntryPredicate filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.removeAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Collection<? extends K> keys,
boolean retval,
CacheEntryPredicate filter,
boolean singleRmv) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.removeAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Collection<? extends K> keys,
boolean retval,
CacheEntryPredicate filter,
boolean singleRmv) |
IgniteInternalFuture<?> |
IgniteTxLocalAdapter.removeAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheVersion> drMap) |
IgniteInternalFuture<?> |
IgniteTxLocalEx.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,
AffinityTopologyVersion 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,
boolean skipStore,
boolean keepBinary)
This constructor is meant for local transactions.
|
IgniteTxEntry(GridCacheContext<?,?> ctx,
IgniteInternalTx tx,
GridCacheOperation op,
CacheObject val,
long ttl,
long conflictExpireTime,
GridCacheEntryEx entry,
GridCacheVersion conflictVer,
boolean skipStore,
boolean keepBinary)
This constructor is meant for remote transactions.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext |
GridCacheLazyPlainVersionedEntry.cctx
Cache context.
|
| Constructor and Description |
|---|
GridCacheLazyPlainVersionedEntry(GridCacheContext cctx,
KeyCacheObject keyObj,
CacheObject valObj,
long ttl,
long expireTime,
GridCacheVersion ver,
boolean keepBinary) |
GridCacheLazyPlainVersionedEntry(GridCacheContext cctx,
KeyCacheObject keyObj,
CacheObject valObj,
long ttl,
long expireTime,
GridCacheVersion ver,
boolean isStartVer,
boolean keepBinary) |
| Modifier and Type | Method and Description |
|---|---|
protected int |
IgniteCacheObjectProcessorImpl.partition(CacheObjectContext ctx,
GridCacheContext cctx,
Object obj) |
CacheObject |
IgniteCacheObjectProcessor.prepareForCache(CacheObject obj,
GridCacheContext cctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
IgniteCacheObjectProcessorImpl.prepareForCache(CacheObject obj,
GridCacheContext cctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
KeyCacheObject |
IgniteCacheObjectProcessor.toCacheKeyObject(CacheObjectContext ctx,
GridCacheContext cctx,
Object obj,
boolean userObj) |
KeyCacheObject |
IgniteCacheObjectProcessorImpl.toCacheKeyObject(CacheObjectContext ctx,
GridCacheContext cctx,
Object obj,
boolean userObj) |
protected KeyCacheObject |
IgniteCacheObjectProcessorImpl.toCacheKeyObject0(CacheObjectContext ctx,
GridCacheContext cctx,
Object obj,
boolean userObj) |
CacheObject |
IgniteCacheObjectProcessor.toCacheObject(GridCacheContext ctx,
long valPtr,
boolean tmp) |
CacheObject |
IgniteCacheObjectProcessorImpl.toCacheObject(GridCacheContext ctx,
long valPtr,
boolean tmp) |
Object |
IgniteCacheObjectProcessor.unwrapTemporary(GridCacheContext ctx,
Object obj)
Converts temporary off-heap object to heap-based.
|
Object |
IgniteCacheObjectProcessorImpl.unwrapTemporary(GridCacheContext ctx,
Object obj)
Converts temporary off-heap object to heap-based.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridContinuousProcessor.onCacheStart(GridCacheContext ctx)
Callback invoked when cache is started.
|
void |
GridContinuousProcessor.onCacheStop(GridCacheContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
<K,V> Map.Entry<K,V> |
DataStreamerEntry.toEntry(GridCacheContext ctx,
boolean keepBinary) |
| 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) |
| Modifier and Type | Method and Description |
|---|---|
<R> R |
GridQueryProcessor.executeQuery(GridCacheQueryType qryType,
String qry,
GridCacheContext<?,?> cctx,
IgniteOutClosureX<R> clo,
boolean complete) |
void |
GridQueryProcessor.onCacheStart(GridCacheContext cctx) |
void |
GridQueryProcessor.onCacheStop(GridCacheContext cctx) |
<K,V> QueryCursor<javax.cache.Cache.Entry<K,V>> |
GridQueryProcessor.queryLocal(GridCacheContext<?,?> cctx,
SqlQuery qry,
boolean keepBinary) |
QueryCursor<List<?>> |
GridQueryProcessor.queryLocalFields(GridCacheContext<?,?> cctx,
SqlFieldsQuery qry) |
<K,V> QueryCursor<javax.cache.Cache.Entry<K,V>> |
GridQueryIndexing.queryLocalSql(GridCacheContext<?,?> cctx,
SqlQuery qry,
IndexingQueryFilter filter,
boolean keepBinary)
Executes regular query.
|
<K,V> QueryCursor<List<?>> |
GridQueryIndexing.queryLocalSqlFields(GridCacheContext<?,?> cctx,
SqlFieldsQuery qry,
IndexingQueryFilter filter,
GridQueryCancel cancel)
Queries individual fields (generally used by JDBC drivers).
|
QueryCursor<List<?>> |
GridQueryProcessor.queryTwoStep(GridCacheContext<?,?> cctx,
SqlFieldsQuery qry) |
QueryCursor<List<?>> |
GridQueryIndexing.queryTwoStep(GridCacheContext<?,?> cctx,
SqlFieldsQuery qry,
GridQueryCancel cancel)
Parses SQL query into two step query and executes it.
|
<K,V> QueryCursor<javax.cache.Cache.Entry<K,V>> |
GridQueryProcessor.queryTwoStep(GridCacheContext<?,?> cctx,
SqlQuery qry) |
<K,V> QueryCursor<javax.cache.Cache.Entry<K,V>> |
GridQueryIndexing.queryTwoStep(GridCacheContext<?,?> cctx,
SqlQuery qry)
Parses SQL query into two step query and executes it.
|
void |
GridQueryIndexing.registerCache(GridCacheContext<?,?> cctx,
CacheConfiguration<?,?> ccfg)
Registers cache.
|
| Constructor and Description |
|---|
GridQueryCacheObjectsIterator(Iterator<List<?>> iter,
GridCacheContext<?,?> cctx,
boolean keepBinary) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.9.0 Release Date : March 2 2017