| Modifier and Type | Method and Description |
|---|---|
GridNearTxLocal |
IgniteTransactionsEx.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
GridNearTxLocal |
IgniteTransactionsEx.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgnitePageStoreManager.shutdownForCache(GridCacheContext cacheCtx,
boolean destroy)
Callback called when a cache is stopping.
|
| 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) |
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.
|
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) |
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 GridNearTxLocal |
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,
GridIntList 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) |
Object |
CacheObjectBinaryProcessorImpl.unwrapTemporary(GridCacheContext ctx,
Object obj)
Converts temporary off-heap object to heap-based.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<?,?> |
RowStore.cctx |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheDataRowAdapter.initFromLink(GridCacheContext<?,?> cctx,
CacheDataRowAdapter.RowData rowData)
Read row from data pages.
|
void |
CacheDataRowAdapter.initFromLink(GridCacheContext<?,?> cctx,
GridCacheSharedContext<?,?> sharedCtx,
PageMemory pageMem,
CacheDataRowAdapter.RowData rowData)
Read row from data pages.
|
void |
IgniteCacheDatabaseSharedManager.onCacheStop(GridCacheContext cctx) |
| Constructor and Description |
|---|
RowStore(GridCacheContext<?,?> cctx,
FreeList freeList) |
| 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,
boolean recovery,
boolean read,
Object key,
Collection<?> keys)
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,
boolean recovery) |
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,
boolean recovery) |
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,
boolean recovery) |
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) |
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,
boolean recovery,
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,
boolean recovery) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext |
GridNearAtomicAbstractUpdateFuture.cctx
Cache context.
|
protected GridCacheContext |
GridDhtAtomicAbstractUpdateFuture.cctx
Cache context.
|
| Constructor and Description |
|---|
GridDhtAtomicAbstractUpdateFuture(GridCacheContext cctx,
GridCacheVersion writeVer,
GridNearAtomicAbstractUpdateRequest updateReq) |
GridDhtAtomicCache(GridCacheContext<K,V> ctx) |
GridDhtAtomicCache(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap map) |
GridDhtAtomicCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
GridNearAtomicAbstractUpdateFuture(GridCacheContext cctx,
GridDhtAtomicCache cache,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
Object[] invokeArgs,
boolean retval,
boolean rawRetval,
javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
UUID subjId,
int taskNameHash,
boolean skipStore,
boolean keepBinary,
boolean recovery,
int remapCnt)
Constructor.
|
GridNearAtomicSingleUpdateFuture(GridCacheContext cctx,
GridDhtAtomicCache cache,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
Object key,
Object val,
Object[] invokeArgs,
boolean retval,
boolean rawRetval,
javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
UUID subjId,
int taskNameHash,
boolean skipStore,
boolean keepBinary,
boolean recovery,
int remapCnt) |
GridNearAtomicUpdateFuture(GridCacheContext cctx,
GridDhtAtomicCache cache,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
Collection<?> keys,
Collection<?> vals,
Object[] invokeArgs,
Collection<GridCacheDrInfo> conflictPutVals,
Collection<GridCacheVersion> conflictRmvVals,
boolean retval,
boolean rawRetval,
javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
UUID subjId,
int taskNameHash,
boolean skipStore,
boolean keepBinary,
boolean recovery,
int remapCnt) |
| 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,
boolean recovery) |
GridDhtDetachedCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
int hdrId) |
| Modifier and Type | Method and Description |
|---|---|
Throwable |
GridDhtPartitionsExchangeFuture.validateCache(GridCacheContext cctx,
boolean recovery,
boolean read,
Object key,
Collection<?> keys)
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) |
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.
|
<K,V> IgniteInternalFuture<Map<K,V>> |
GridNearTxLocal.getAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Collection<KeyCacheObject> keys,
boolean deserializeBinary,
boolean skipVals,
boolean keepCacheObjects,
boolean skipStore,
boolean recovery,
boolean needVer) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.invokeAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
K key,
javax.cache.processor.EntryProcessor<K,V,Object> entryProcessor,
Object... invokeArgs) |
<K,V,T> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.invokeAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,Object>> map,
Object... invokeArgs) |
IgniteInternalFuture<Void> |
GridNearTxLocal.loadMissing(GridCacheContext cacheCtx,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean async,
Collection<KeyCacheObject> keys,
boolean skipVals,
boolean needVer,
boolean keepBinary,
boolean recovery,
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) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.putAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Map<? extends K,? extends V> map,
boolean retval) |
IgniteInternalFuture<?> |
GridNearTxLocal.putAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheDrInfo> drMap) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.putAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
K key,
V val,
boolean retval,
CacheEntryPredicate filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.removeAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Collection<? extends K> keys,
boolean retval,
CacheEntryPredicate filter,
boolean singleRmv) |
IgniteInternalFuture<?> |
GridNearTxLocal.removeAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheVersion> drMap) |
| Constructor and Description |
|---|
GridNearAtomicCache(GridCacheContext<K,V> ctx) |
GridNearCacheAdapter(GridCacheContext<K,V> ctx) |
GridNearCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val) |
GridNearGetFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
IgniteTxLocalEx tx,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean canRemap,
boolean needVer,
boolean keepCacheObjects,
boolean recovery) |
GridNearLockFuture(GridCacheContext<?,?> cctx,
Collection<KeyCacheObject> keys,
GridNearTxLocal tx,
boolean read,
boolean retval,
long timeout,
long createTtl,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore,
boolean keepBinary,
boolean recovery) |
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) |
| 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,
boolean recovery)
Adds cache to the list of active caches in transaction.
|
void |
IgniteTxImplicitSingleStateImpl.addActiveCache(GridCacheContext ctx,
boolean recovery,
IgniteTxLocalAdapter tx) |
void |
IgniteTxStateImpl.addActiveCache(GridCacheContext cacheCtx,
boolean recovery,
IgniteTxLocalAdapter tx) |
void |
IgniteTxRemoteStateAdapter.addActiveCache(GridCacheContext cacheCtx,
boolean recovery,
IgniteTxLocalAdapter tx) |
void |
IgniteTxState.addActiveCache(GridCacheContext cacheCtx,
boolean recovery,
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) |
void |
TxEntryValueHolder.marshal(GridCacheContext<?,?> ctx) |
GridNearTxLocal |
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) |
GridNearTxLocal |
IgniteTxManager.threadLocalTx(GridCacheContext cctx) |
GridNearTxLocal |
IgniteTransactionsImpl.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
GridNearTxLocal |
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.
|
| 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) |
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 |
|---|---|
boolean |
GridQueryProcessor.belongsToTable(GridCacheContext cctx,
String expSpace,
String expTblName,
KeyCacheObject key,
CacheObject val)
Check whether provided key and value belongs to expected space and table.
|
<R> R |
GridQueryProcessor.executeQuery(GridCacheQueryType qryType,
String qry,
GridCacheContext<?,?> cctx,
IgniteOutClosureX<R> clo,
boolean complete) |
void |
GridQueryProcessor.onCacheStart(GridCacheContext cctx,
QuerySchema schema)
Handle cache start.
|
void |
GridQueryProcessor.onCacheStart0(GridCacheContext<?,?> cctx,
QuerySchema schema)
Create type descriptors from schema and initialize indexing for given cache.
|
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(String spaceName,
GridCacheContext<?,?> cctx,
CacheConfiguration<?,?> ccfg)
Registers cache.
|
static QueryTypeCandidate |
QueryUtils.typeForQueryEntity(String space,
GridCacheContext cctx,
QueryEntity qryEntity,
List<Class<?>> mustDeserializeClss)
Create type candidate for query entity.
|
| Constructor and Description |
|---|
GridQueryCacheObjectsIterator(Iterator<List<?>> iter,
GridCacheContext<?,?> cctx,
boolean keepBinary) |
| Constructor and Description |
|---|
SchemaIndexCacheVisitorImpl(GridQueryProcessor qryProc,
GridCacheContext cctx,
String spaceName,
String tblName,
SchemaIndexOperationCancellationToken cancel)
Constructor.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 2.0.0 Release Date : April 30 2017