| 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 | Field and Description |
|---|---|
protected GridCacheContext<?,?> |
GridCacheMapEntry.cctx
Cache registry.
|
protected GridCacheContext |
GridCacheManagerAdapter.cctx
Context.
|
protected GridCacheContext |
CacheLazyEntry.cctx
Cache context.
|
GridCacheContext |
GridCacheConcurrentMap.CacheMapHolder.cctx |
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> |
GatewayProtectedCacheProxy.context() |
protected GridCacheContext<K,V> |
GridCacheManagerAdapter.context() |
GridCacheContext<K,V> |
IgniteCacheProxy.context() |
GridCacheContext<K,V> |
GridCacheProxyImpl.context() |
GridCacheContext<K,V> |
IgniteInternalCache.context() |
GridCacheContext<K,V> |
GridCacheAdapter.context() |
GridCacheContext<K,V> |
IgniteCacheProxyImpl.context() |
<K,V> GridCacheContext<K,V> |
GridCacheEntryEx.context() |
<K,V> GridCacheContext<K,V> |
GridCacheMapEntry.context() |
static GridCacheContext<?,?> |
GridCacheUtils.firstPartitioned(GridCacheSharedContext<?,?> sctx,
int[] cacheIds) |
static GridCacheContext<?,?> |
GridCacheUtils.firstPartitioned(GridCacheSharedContext<?,?> sctx,
Iterable<Integer> cacheIds) |
GridCacheContext |
CacheGroupContext.singleCacheContext() |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCacheContext> |
GridCacheSharedContext.cacheContexts()
Gets all cache contexts for local node.
|
List<GridCacheContext> |
CacheGroupContext.caches() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheSharedContext.addCacheContext(GridCacheContext cacheCtx)
Adds cache context to shared cache context.
|
void |
CacheGroupContext.addCacheWithContinuousQuery(GridCacheContext cctx) |
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,
AffinityTopologyVersion topVer)
Gets DHT affinity nodes.
|
<K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>> |
IgniteCacheOffheapManager.cacheEntriesIterator(GridCacheContext cctx,
boolean primary,
boolean backup,
AffinityTopologyVersion topVer,
boolean keepBinary) |
<K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>> |
IgniteCacheOffheapManagerImpl.cacheEntriesIterator(GridCacheContext cctx,
boolean primary,
boolean backup,
AffinityTopologyVersion topVer,
boolean keepBinary) |
static void |
GridCacheUtils.checkStore(GridCacheContext<?,?> ctx)
Checks that cache store is present.
|
int |
IgniteCacheOffheapManager.CacheDataStore.cleanup(GridCacheContext cctx,
List<MvccLinkAwareSearchRow> cleanupRows) |
int |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cleanup(GridCacheContext cctx,
List<MvccLinkAwareSearchRow> cleanupRows) |
void |
IgniteCacheOffheapManager.clearCache(GridCacheContext cctx,
boolean readers)
Clears offheap entries.
|
void |
IgniteCacheOffheapManagerImpl.clearCache(GridCacheContext cctx,
boolean readers)
Clears offheap entries.
|
boolean |
GridCacheSharedContext.closed(GridCacheContext ctx)
Checks if cache context is closed.
|
GridCacheMapEntry |
GridCacheMapEntryFactory.create(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key) |
static GridCacheUtils.BackupPostProcessingClosure |
GridCacheUtils.createBackupPostProcessingClosure(AffinityTopologyVersion topVer,
IgniteLogger log,
GridCacheContext cctx,
KeyCacheObject key,
IgniteCacheExpiryPolicy expiryPlc,
boolean readThrough,
boolean skipVals)
Creates closure that saves initial value to backup partition.
|
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
protected abstract GridCacheConcurrentMap.CacheMapHolder |
GridCacheConcurrentMapImpl.entriesMap(GridCacheContext cctx) |
protected GridCacheConcurrentMap.CacheMapHolder |
GridCacheLocalConcurrentMap.entriesMap(GridCacheContext cctx) |
boolean |
IgniteCacheOffheapManager.expire(GridCacheContext cctx,
IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c,
int amount) |
boolean |
IgniteCacheOffheapManagerImpl.expire(GridCacheContext cctx,
IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c,
int amount) |
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.find(GridCacheContext cctx,
KeyCacheObject key) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.find(GridCacheContext cctx,
KeyCacheObject key) |
void |
CacheEntryPredicateAdapter.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntrySerializablePredicate.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
GridCacheReturn.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicateContainsValue.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheInvokeDirectResult.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEvictionEntry.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicate.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) |
GridCacheMapEntry |
GridNoStorageCacheMap.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
GridCacheMapEntry |
GridCacheConcurrentMapImpl.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
GridCacheMapEntry |
GridCacheConcurrentMap.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
protected void |
IgniteCacheOffheapManagerImpl.initPendingTree(GridCacheContext cctx) |
void |
IgniteCacheOffheapManager.invoke(GridCacheContext cctx,
KeyCacheObject key,
GridDhtLocalPartition part,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
IgniteCacheOffheapManagerImpl.invoke(GridCacheContext cctx,
KeyCacheObject key,
GridDhtLocalPartition part,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
IgniteCacheOffheapManager.CacheDataStore.invoke(GridCacheContext cctx,
KeyCacheObject key,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.invoke(GridCacheContext cctx,
KeyCacheObject key,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
static boolean |
GridCacheUtils.isNearEnabled(GridCacheContext ctx)
Checks if near cache is enabled for cache context.
|
boolean |
GridCacheMvccManager.isRemoved(GridCacheContext cacheCtx,
GridCacheVersion ver) |
void |
GridCacheEntryInfo.marshal(GridCacheContext ctx) |
static byte[] |
GridCacheUtils.marshal(GridCacheContext ctx,
Object obj) |
protected List<byte[]> |
GridCacheMessage.marshalCollection(Collection<?> col,
GridCacheContext ctx) |
protected byte[][] |
GridCacheMessage.marshalInvokeArguments(Object[] args,
GridCacheContext ctx) |
void |
GridCacheReturn.marshalResult(GridCacheContext ctx)
Converts entry processor invokation results to cache object instances.
|
void |
CacheInvokeDirectResult.marshalResult(GridCacheContext ctx)
Converts the entry processor unprepared result to a cache object instance.
|
List<IgniteBiTuple<Object,MvccVersion>> |
IgniteCacheOffheapManager.mvccAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
List<IgniteBiTuple<Object,MvccVersion>> |
IgniteCacheOffheapManagerImpl.mvccAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
GridCursor<CacheDataRow> |
IgniteCacheOffheapManager.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
GridCursor<CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
GridCursor<CacheDataRow> |
IgniteCacheOffheapManagerImpl.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
GridCursor<CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
void |
IgniteCacheOffheapManager.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManagerImpl.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManager.CacheDataStore.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.mvccFind(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccFind(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot) |
List<IgniteBiTuple<Object,MvccVersion>> |
IgniteCacheOffheapManager.CacheDataStore.mvccFindAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
List<IgniteBiTuple<Object,MvccVersion>> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccFindAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccInitialValueIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte txState,
byte newTxState) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccInitialValueIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte txState,
byte newTxState) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccLock(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccLock(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
CacheDataRow |
IgniteCacheOffheapManager.mvccRead(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot ver) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.mvccRead(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot ver) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccRemove(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot,
CacheEntryPredicate filter,
boolean primary,
boolean needHistory,
boolean needOldVal,
boolean retVal) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccRemove(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot,
CacheEntryPredicate filter,
boolean primary,
boolean needHistory,
boolean needOldVal,
boolean retVal) |
void |
IgniteCacheOffheapManager.CacheDataStore.mvccRemoveAll(GridCacheContext cctx,
KeyCacheObject key) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccRemoveAll(GridCacheContext cctx,
KeyCacheObject key) |
GridLongList |
IgniteCacheOffheapManager.CacheDataStore.mvccRemoveNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
GridLongList |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccRemoveNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHist,
boolean noCreate,
boolean needOldVal,
boolean retVal) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
boolean retVal) |
GridLongList |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdateNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot) |
GridLongList |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdateNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot) |
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState) |
void |
IgniteCacheOffheapManager.onCacheStarted(GridCacheContext cctx) |
void |
IgniteCacheOffheapManagerImpl.onCacheStarted(GridCacheContext cctx) |
void |
IgniteCacheProxyImpl.onRestarted(GridCacheContext ctx,
IgniteInternalCache delegate)
Mark this proxy as restarted.
|
void |
GridCacheDeploymentManager.onUndeploy(ClassLoader ldr,
GridCacheContext<K,V> ctx)
Undeploys given class loader.
|
void |
CacheEntryPredicateAdapter.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntrySerializablePredicate.prepareMarshal(GridCacheContext ctx) |
void |
GridCacheReturn.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicateContainsValue.prepareMarshal(GridCacheContext ctx) |
void |
CacheInvokeDirectResult.prepareMarshal(GridCacheContext ctx) |
void |
CacheEvictionEntry.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicate.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) |
protected GridCacheMapEntry |
GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(GridCacheConcurrentMap.CacheMapHolder hld,
GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
GridCacheMapEntry |
GridNoStorageCacheMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
GridCacheMapEntry |
GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
GridCacheMapEntry |
GridCacheConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
CacheDataRow |
IgniteCacheOffheapManager.read(GridCacheContext cctx,
KeyCacheObject key) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.read(GridCacheContext cctx,
KeyCacheObject key) |
void |
IgniteCacheOffheapManager.CacheDataStore.remove(GridCacheContext cctx,
KeyCacheObject key,
int partId) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.remove(GridCacheContext cctx,
KeyCacheObject key,
int partId) |
void |
IgniteCacheOffheapManager.remove(GridCacheContext cctx,
KeyCacheObject key,
int partId,
GridDhtLocalPartition part) |
void |
IgniteCacheOffheapManagerImpl.remove(GridCacheContext cctx,
KeyCacheObject key,
int partId,
GridDhtLocalPartition part) |
void |
CacheGroupContext.removeCacheWithContinuousQuery(GridCacheContext cctx) |
GridDhtFuture<Object> |
GridCachePreloader.request(GridCacheContext cctx,
Collection<KeyCacheObject> keys,
AffinityTopologyVersion topVer)
Requests that preloader sends the request for the key.
|
GridDhtFuture<Object> |
GridCachePreloaderAdapter.request(GridCacheContext ctx,
Collection<KeyCacheObject> keys,
AffinityTopologyVersion topVer)
Requests that preloader sends the request for the key.
|
GridDhtFuture<Object> |
GridCachePreloader.request(GridCacheContext cctx,
GridNearAtomicAbstractUpdateRequest req,
AffinityTopologyVersion topVer)
Requests that preloader sends the request for the key.
|
GridDhtFuture<Object> |
GridCachePreloaderAdapter.request(GridCacheContext ctx,
GridNearAtomicAbstractUpdateRequest req,
AffinityTopologyVersion topVer)
Requests that preloader sends the request for the key.
|
GridCacheReturn |
GridCacheReturn.set(GridCacheContext cctx,
CacheObject cacheObj,
boolean success,
boolean keepBinary) |
void |
GridCacheManagerAdapter.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
CacheOsConflictResolutionManager.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
GridCacheManager.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
CacheAffinitySharedManager.stopCacheOnReconnect(GridCacheContext cctx) |
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) |
void |
IgniteCacheOffheapManager.CacheDataStore.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManager.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManager.CacheDataStore.updateTxState(GridCacheContext cctx,
CacheSearchRow row) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.updateTxState(GridCacheContext cctx,
CacheSearchRow row) |
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 | Method and Description |
|---|---|
void |
GridDistributedTxRemoteAdapter.addActiveCache(GridCacheContext cacheCtx,
boolean recovery)
Adds cache to the list of active caches in transaction.
|
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) |
GridDistributedCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap map) |
GridDistributedCacheEntry(GridCacheContext ctx,
KeyCacheObject key) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<K,V> |
CacheDistributedGetFutureAdapter.cctx
Context.
|
protected GridCacheContext<?,?> |
GridDhtTxAbstractEnlistFuture.cctx
Cache registry.
|
| 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) |
GridCacheMapEntry |
GridCachePartitionedConcurrentMap.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
IgniteInternalFuture<GridNearLockResponse> |
GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<?,?> cacheCtx,
ClusterNode nearNode,
GridNearLockRequest req,
CacheEntryPredicate[] filter0) |
void |
GridInvokeValue.prepareMarshal(GridCacheContext ctx)
Marshalls invoke value.
|
GridCacheMapEntry |
GridCachePartitionedConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
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 |
GridDhtTopologyFutureAdapter.validateCache(GridCacheContext cctx,
boolean recovery,
boolean read,
Object key,
Collection<?> keys)
Returns error is cache topology is not valid.
|
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 needVer,
boolean keepCacheObjects,
boolean recovery) |
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) |
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,
boolean addReaders,
MvccSnapshot mvccSnapshot) |
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,
MvccSnapshot mvccSnapshot) |
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) |
GridDhtTransactionalCacheAdapter(GridCacheContext<K,V> ctx) |
GridDhtTransactionalCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap map)
Constructor used for near-only cache.
|
GridDhtTxAbstractEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
int[] parts,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
CacheEntryPredicate filter) |
GridDhtTxEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
Collection<Object> rows,
EnlistOperation op,
CacheEntryPredicate filter,
boolean needRes)
Constructor.
|
GridDhtTxQueryAbstractEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
int[] parts,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx)
Constructor.
|
GridDhtTxQueryEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
int[] cacheIds,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
long timeout,
GridCacheContext<?,?> cctx) |
GridDhtTxQueryResultsEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
Collection<Object> rows,
EnlistOperation op) |
GridPartitionedGetFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
MvccSnapshot mvccSnapshot) |
GridPartitionedSingleGetFuture(GridCacheContext cctx,
KeyCacheObject key,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
boolean recovery,
MvccSnapshot mvccSnapshot) |
| 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) |
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.
|
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) |
| Modifier and Type | Method and Description |
|---|---|
GridDhtFuture<Object> |
GridDhtPreloader.request(GridCacheContext cctx,
Collection<KeyCacheObject> keys,
AffinityTopologyVersion topVer) |
GridDhtFuture<Object> |
GridDhtPreloader.request(GridCacheContext cctx,
GridNearAtomicAbstractUpdateRequest req,
AffinityTopologyVersion topVer)
Requests that preloader sends the request for the key.
|
| Constructor and Description |
|---|
GridDhtForceKeysFuture(GridCacheContext<K,V> cctx,
AffinityTopologyVersion topVer,
Collection<KeyCacheObject> keys) |
| Modifier and Type | Method and Description |
|---|---|
protected GridCacheConcurrentMap.CacheMapHolder |
GridDhtLocalPartition.entriesMap(GridCacheContext cctx) |
| Constructor and Description |
|---|
GridDhtPartitionsReservation(AffinityTopologyVersion topVer,
GridCacheContext<?,?> cctx,
Object appKey) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<?,?> |
GridNearTxAbstractEnlistFuture.cctx
Cache context.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheContext<?,?> |
GridNearTxSelectForUpdateFuture.cache() |
| 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) |
void |
GridNearTxRemote.addActiveCache(GridCacheContext cacheCtx,
boolean recovery)
Adds cache to the list of active caches in transaction.
|
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) |
<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) |
IgniteInternalFuture<Long> |
GridNearTxLocal.updateAsync(GridCacheContext cacheCtx,
int[] cacheIds,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
long timeout) |
IgniteInternalFuture<Long> |
GridNearTxLocal.updateAsync(GridCacheContext cacheCtx,
UpdateSourceIterator<?> it,
int pageSize,
long timeout,
boolean sequential) |
protected void |
GridNearTxLocal.validateTxMode(GridCacheContext ctx)
Validate Tx mode.
|
| 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 | Method and Description |
|---|---|
GridCacheContext |
MvccQueryTracker.context() |
GridCacheContext |
StaticMvccQueryTracker.context() |
GridCacheContext |
MvccQueryTrackerImpl.context() |
| Modifier and Type | Method and Description |
|---|---|
Map<UUID,CacheContinuousQueryListener> |
MvccCachingManager.continuousQueryListeners(GridCacheContext ctx0,
IgniteInternalTx tx,
KeyCacheObject key) |
static MvccVersion |
MvccUtils.getNewVersion(GridCacheContext cctx,
long link)
Returns new version of row (xid_max) if any.
|
static int |
MvccUtils.getVisibleState(GridCacheContext cctx,
long link,
MvccSnapshot snapshot)
Checks if a row's new version is visible for the given snapshot.
|
static boolean |
MvccUtils.isActive(GridCacheContext cctx,
long mvccCrd,
long mvccCntr,
MvccSnapshot snapshot) |
static boolean |
MvccUtils.isVisible(GridCacheContext cctx,
MvccSnapshot snapshot,
long mvccCrd,
long mvccCntr,
int opCntr)
Checks if version is visible from the given snapshot.
|
static boolean |
MvccUtils.isVisible(GridCacheContext cctx,
MvccSnapshot snapshot,
long mvccCrd,
long mvccCntr,
int opCntr,
boolean useTxLog)
Checks if version is visible from the given snapshot.
|
static boolean |
MvccUtils.isVisible(GridCacheContext cctx,
MvccSnapshot snapshot,
long crd,
long cntr,
int opCntr,
long link)
Checks visibility of the given row versions from the given snapshot.
|
static MvccQueryTracker |
MvccUtils.mvccTracker(GridCacheContext cctx,
boolean startTx)
Initialises MVCC filter and returns MVCC query tracker if needed.
|
static MvccQueryTracker |
MvccUtils.mvccTracker(GridCacheContext cctx,
GridNearTxLocal tx)
Initialises MVCC filter and returns MVCC query tracker if needed.
|
boolean |
MvccCachingManager.needDrReplicate(GridCacheContext ctx0,
KeyCacheObject key) |
static MvccSnapshot |
MvccUtils.requestSnapshot(GridCacheContext cctx,
GridNearTxLocal tx) |
static byte |
MvccUtils.state(GridCacheContext cctx,
long mvccCrd,
long mvccCntr,
int mvccOpCntr) |
static void |
MvccUtils.throwAtomicityModesMismatchException(GridCacheContext ctx1,
GridCacheContext ctx2)
Throws atomicity modes compatibility validation exception.
|
static void |
MvccUtils.throwAtomicityModesMismatchException(GridCacheContext ctx1,
GridCacheContext ctx2)
Throws atomicity modes compatibility validation exception.
|
static GridNearTxLocal |
MvccUtils.txStart(GridCacheContext cctx,
long timeout) |
static IgniteTxMvccVersionCheckedException |
MvccUtils.unexpectedStateException(GridCacheContext cctx,
byte state,
long crd,
long cntr,
int opCntr,
MvccSnapshot snapshot) |
static void |
MvccUtils.verifyMvccOperationSupport(GridCacheContext<?,?> cctx,
String opType)
Throw an
UnsupportedOperationException if this cache is transactional and MVCC is enabled with
appropriate message about corresponding operation type. |
IgniteInternalFuture<Void> |
MvccProcessorImpl.waitFor(GridCacheContext cctx,
MvccVersion locked) |
IgniteInternalFuture<Void> |
MvccProcessor.waitFor(GridCacheContext cctx,
MvccVersion locked) |
| Constructor and Description |
|---|
MvccQueryTrackerImpl(GridCacheContext cctx) |
MvccQueryTrackerImpl(GridCacheContext cctx,
boolean canRemap) |
StaticMvccQueryTracker(GridCacheContext cctx,
MvccSnapshot snapshot) |
| Modifier and Type | Method and Description |
|---|---|
int |
GridCacheOffheapManager.GridCacheDataStore.cleanup(GridCacheContext cctx,
List<MvccLinkAwareSearchRow> cleanupRows) |
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
boolean |
GridCacheOffheapManager.expire(GridCacheContext cctx,
IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c,
int amount) |
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.find(GridCacheContext cctx,
KeyCacheObject key) |
protected void |
GridCacheOffheapManager.initPendingTree(GridCacheContext cctx) |
void |
GridCacheOffheapManager.GridCacheDataStore.invoke(GridCacheContext cctx,
KeyCacheObject key,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
GridCursor<CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
void |
GridCacheOffheapManager.GridCacheDataStore.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.mvccFind(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot) |
List<IgniteBiTuple<Object,MvccVersion>> |
GridCacheOffheapManager.GridCacheDataStore.mvccFindAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccInitialValueIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte txState,
byte newTxState) |
MvccUpdateResult |
GridCacheOffheapManager.GridCacheDataStore.mvccLock(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
MvccUpdateResult |
GridCacheOffheapManager.GridCacheDataStore.mvccRemove(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccVer,
CacheEntryPredicate filter,
boolean primary,
boolean needHistory,
boolean needOldVal,
boolean retVal) |
void |
GridCacheOffheapManager.GridCacheDataStore.mvccRemoveAll(GridCacheContext cctx,
KeyCacheObject key) |
GridLongList |
GridCacheOffheapManager.GridCacheDataStore.mvccRemoveNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
MvccUpdateResult |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccVer,
CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
boolean retVal) |
GridLongList |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdateNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState) |
int |
GridCacheOffheapManager.GridCacheDataStore.purgeExpired(GridCacheContext cctx,
IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c,
int amount)
Try to remove expired entries from data store.
|
void |
GridCacheOffheapManager.GridCacheDataStore.remove(GridCacheContext cctx,
KeyCacheObject key,
int partId) |
void |
GridCacheOffheapManager.GridCacheDataStore.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
void |
GridCacheOffheapManager.GridCacheDataStore.updateTxState(GridCacheContext cctx,
CacheSearchRow row) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheSnapshotManager.onCacheStop(GridCacheContext cctx) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<K,V> |
GridCacheQueryFutureAdapter.cctx
Cache context.
|
| Modifier and Type | Method and Description |
|---|---|
CounterSkipContext |
CacheContinuousQueryListener.skipUpdateCounter(GridCacheContext cctx,
CounterSkipContext skipCtx,
int part,
long cntr,
AffinityTopologyVersion topVer,
boolean primary)
For cache updates in shared cache group need notify others caches CQ listeners
that generated counter should be skipped.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheContext<?,?> |
IgniteTxEntry.context() |
GridCacheContext |
IgniteTxImplicitSingleStateImpl.singleCacheContext(GridCacheSharedContext cctx) |
GridCacheContext |
IgniteTxState.singleCacheContext(GridCacheSharedContext cctx) |
GridCacheContext |
IgniteTxStateImpl.singleCacheContext(GridCacheSharedContext cctx) |
GridCacheContext |
IgniteTxRemoteStateAdapter.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) |
abstract void |
IgniteTxAdapter.addActiveCache(GridCacheContext cacheCtx,
boolean recovery)
Adds cache to the list of active caches in transaction.
|
void |
IgniteTxLocalAdapter.addActiveCache(GridCacheContext cacheCtx,
boolean recovery)
Adds cache to the list of active caches in transaction.
|
void |
IgniteTxImplicitSingleStateImpl.addActiveCache(GridCacheContext ctx,
boolean recovery,
IgniteTxAdapter tx) |
void |
IgniteTxState.addActiveCache(GridCacheContext cacheCtx,
boolean recovery,
IgniteTxAdapter tx) |
void |
IgniteTxStateImpl.addActiveCache(GridCacheContext cacheCtx,
boolean recovery,
IgniteTxAdapter tx) |
void |
IgniteTxRemoteStateAdapter.addActiveCache(GridCacheContext cctx,
boolean recovery,
IgniteTxAdapter tx) |
void |
IgniteTxAdapter.addInvalidPartition(GridCacheContext<?,?> cacheCtx,
int part) |
void |
IgniteInternalTx.addInvalidPartition(GridCacheContext<?,?> cacheCtx,
int part) |
IgniteTxEntry |
IgniteTxEntry.cleanCopy(GridCacheContext<?,?> ctx) |
void |
IgniteTxEntry.context(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) |
void |
IgniteTxHandler.mvccEnlistBatch(GridDhtTxRemote tx,
GridCacheContext ctx,
EnlistOperation op,
List<KeyCacheObject> keys,
List<Message> vals,
MvccSnapshot snapshot,
IgniteUuid futId,
int batchNum)
Writes updated values on the backup node.
|
GridNearTxLocal |
IgniteTxManager.newTx(boolean implicit,
boolean implicitSingle,
GridCacheContext sysCacheCtx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean storeEnabled,
Boolean mvccOp,
int txSize,
String lb) |
<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,
boolean addReader)
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.
|
| Constructor and Description |
|---|
MvccUpdateDataRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
MvccSnapshot mvccSnapshot,
MvccVersion newVer,
CacheEntryPredicate filter,
boolean primary,
boolean lockOnly,
boolean needHist,
boolean fastUpdate,
boolean needOldVal,
boolean needPrevValue) |
MvccUpdateDataRowNative(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
MvccVersion newVer,
int part,
GridCacheContext cctx) |
| Constructor and Description |
|---|
MvccFirstRowTreeClosure(GridCacheContext cctx) |
MvccSnapshotSearchRow(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot)
Constructor.
|
| 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.
|
protected GridCacheContext<GridCacheInternalKey,V> |
AtomicDataStructureProxy.ctx
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) |
| Constructor and Description |
|---|
GridAtomicCacheQueueImpl(String queueName,
GridCacheQueueHeader hdr,
GridCacheContext<?,?> cctx) |
GridCacheQueueAdapter(String queueName,
GridCacheQueueHeader hdr,
GridCacheContext<?,?> cctx) |
GridCacheQueueProxy(GridCacheContext cctx,
GridCacheQueueAdapter<T> delegate) |
GridCacheSetImpl(GridCacheContext ctx,
String name,
GridCacheSetHeader hdr) |
GridCacheSetProxy(GridCacheContext cctx,
GridCacheSetImpl<T> delegate) |
GridTransactionalCacheQueueImpl(String queueName,
GridCacheQueueHeader hdr,
GridCacheContext<?,?> cctx) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridQueryProcessor.belongsToTable(GridCacheContext cctx,
String expCacheName,
String expTblName,
KeyCacheObject key,
CacheObject val)
Check whether provided key and value belongs to expected cache 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,
boolean removeIdx) |
void |
GridQueryProcessor.onCacheStop0(GridCacheContext cctx,
boolean destroy)
Unregister cache.
|
UpdateSourceIterator<?> |
GridQueryIndexing.prepareDistributedUpdate(GridCacheContext<?,?> cctx,
int[] ids,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
int timeout,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot,
GridQueryCancel cancel) |
UpdateSourceIterator<?> |
GridQueryProcessor.prepareDistributedUpdate(GridCacheContext<?,?> cctx,
int[] cacheIds,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
int timeout,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot,
GridQueryCancel cancel) |
<K,V> QueryCursor<javax.cache.Cache.Entry<K,V>> |
GridQueryProcessor.querySql(GridCacheContext<?,?> cctx,
SqlQuery qry,
boolean keepBinary)
Execute distributed SQL query.
|
List<FieldsQueryCursor<List<?>>> |
GridQueryProcessor.querySqlFields(GridCacheContext<?,?> cctx,
SqlFieldsQuery qry,
SqlClientContext cliCtx,
boolean keepBinary,
boolean failOnMultipleStmts)
Query SQL fields.
|
void |
GridQueryIndexing.registerCache(String cacheName,
String schemaName,
GridCacheContext<?,?> cctx)
Registers cache.
|
boolean |
GridQueryIndexing.registerType(GridCacheContext cctx,
GridQueryTypeDescriptor desc)
Registers type if it was not known before or updates it otherwise.
|
void |
GridQueryProcessor.remove(GridCacheContext cctx,
CacheDataRow row) |
void |
GridQueryIndexing.remove(GridCacheContext cctx,
GridQueryTypeDescriptor type,
CacheDataRow row)
Removes index entry by key.
|
void |
GridQueryProcessor.store(GridCacheContext cctx,
CacheDataRow newRow,
CacheDataRow prevRow,
boolean prevRowAvailable) |
void |
GridQueryIndexing.store(GridCacheContext cctx,
GridQueryTypeDescriptor type,
CacheDataRow row,
CacheDataRow prevRow,
boolean prevRowAvailable)
Updates index.
|
static QueryTypeCandidate |
QueryUtils.typeForQueryEntity(String cacheName,
String schemaName,
GridCacheContext cctx,
QueryEntity qryEntity,
List<Class<?>> mustDeserializeClss,
boolean escape)
Create type candidate for query entity.
|
void |
GridQueryIndexing.unregisterCache(GridCacheContext cctx,
boolean rmvIdx)
Unregisters cache.
|
| Constructor and Description |
|---|
SchemaIndexCacheVisitorImpl(GridCacheContext cctx)
Constructor.
|
SchemaIndexCacheVisitorImpl(GridCacheContext cctx,
SchemaIndexCacheFilter rowFilter,
SchemaIndexOperationCancellationToken cancel,
int parallelism)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
static BaselineTopology |
IgniteUtils.getBaselineTopology(GridCacheContext cctx) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.5 Release Date : June 4 2019