| 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 |
|---|---|
Index |
IndexFactory.createIndex(@Nullable GridCacheContext<?,?> cctx,
IndexDefinition definition)
Creates index by specified definition for specified cache.
|
Index |
IndexProcessor.createIndex(GridCacheContext<?,?> cctx,
IndexFactory factory,
IndexDefinition definition)
Creates a new index.
|
Index |
IndexProcessor.createIndexDynamically(GridCacheContext cctx,
IndexFactory factory,
IndexDefinition definition,
SchemaIndexCacheVisitor cacheVisitor)
Creates a new index.
|
Collection<Index> |
IndexProcessor.indexes(GridCacheContext<?,?> cctx)
Returns collection of indexes for specified cache.
|
void |
IndexProcessor.markRebuildIndexesForCache(GridCacheContext<?,?> cctx,
boolean val)
Mark/unmark for rebuild indexes for a specific cache.
|
@Nullable IgniteInternalFuture<?> |
IndexProcessor.rebuildIndexesForCache(GridCacheContext<?,?> cctx,
boolean force)
Start rebuild of indexes for specified cache.
|
void |
IndexProcessor.removeIndex(GridCacheContext<?,?> cctx,
IndexName idxName,
boolean softDelete)
Removes an index.
|
void |
IndexProcessor.store(GridCacheContext<?,?> cctx,
CacheDataRow newRow,
@Nullable CacheDataRow prevRow,
boolean prevRowAvailable)
Updates index with new row.
|
List<InlineIndex> |
IndexProcessor.treeIndexes(GridCacheContext cctx,
boolean createdOnly)
Collect indexes for rebuild.
|
| Modifier and Type | Method and Description |
|---|---|
protected InlineIndexTree |
DefragIndexFactory.createIndexSegment(GridCacheContext<?,?> cctx,
SortedIndexDefinition def,
RootPage rootPage,
IoStatisticsHolder stats,
InlineRecommender recommender,
int segmentNum) |
protected RootPage |
DefragIndexFactory.rootPage(GridCacheContext<?,?> ctx,
String treeName,
int segment) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheContext<?,?> |
InlineIndexTree.cacheContext() |
| Modifier and Type | Method and Description |
|---|---|
Index |
InlineIndexFactory.createIndex(GridCacheContext<?,?> cctx,
IndexDefinition def)
Creates index by specified definition for specified cache.
|
protected InlineIndexTree |
InlineIndexFactory.createIndexSegment(GridCacheContext<?,?> cctx,
SortedIndexDefinition def,
RootPage rootPage,
IoStatisticsHolder stats,
InlineRecommender recommender,
int segmentNum) |
protected RootPage |
InlineIndexFactory.rootPage(GridCacheContext<?,?> ctx,
String treeName,
int segment) |
| Constructor and Description |
|---|
InlineIndexImpl(GridCacheContext<?,?> cctx,
SortedIndexDefinition def,
InlineIndexTree[] segments,
IoStatisticsHolderIndex stats)
Constructor.
|
InlineIndexTree(SortedIndexDefinition def,
GridCacheContext<?,?> cctx,
String treeName,
IgniteCacheOffheapManager offheap,
ReuseList reuseList,
PageMemory pageMemory,
PageIoResolver pageIoResolver,
long metaPageId,
boolean initNew,
int configuredInlineSize,
IndexKeyTypeSettings keyTypeSettings,
@Nullable IndexRowCache idxRowCache,
@Nullable IoStatisticsHolder stats,
InlineIndexRowHandlerFactory rowHndFactory,
InlineRecommender recommender)
Constructor.
|
InlineRecommender(GridCacheContext<?,?> cctx,
SortedIndexDefinition def)
Constructor.
|
InlineTreeFilterClosure(IndexingQueryCacheFilter filter,
MvccSnapshot mvccSnapshot,
GridCacheContext<?,?> cctx,
IgniteLogger log)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteInternalFuture<?> |
IndexesRebuildTask.rebuild(GridCacheContext cctx,
boolean force)
Start to rebuild.
|
protected void |
IndexesRebuildTask.startRebuild(GridCacheContext cctx,
GridFutureAdapter<Void> fut,
SchemaIndexCacheVisitorClosure clo,
SchemaIndexOperationCancellationToken cancel)
Actual start rebuilding.
|
| Constructor and Description |
|---|
ScanQuerySystemView(Collection<GridCacheContext<K,V>> cctxs) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<?,?> |
GridCacheMapEntry.cctx
Cache registry.
|
protected GridCacheContext |
GridCacheManagerAdapter.cctx
Context.
|
GridCacheContext |
GridCacheConcurrentMap.CacheMapHolder.cctx |
protected GridCacheContext |
CacheLazyEntry.cctx
Cache context.
|
protected GridCacheContext<K,V> |
GridCacheAdapter.ctx
Cache configuration.
|
protected GridCacheContext<K,V> |
GridCacheClearAllRunnable.ctx
Cache context.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridCacheContext<K,V> |
GridCacheContextInfo.cacheContext() |
GridCacheContext<K,V> |
GridCacheSharedContext.cacheContext(int cacheId)
Gets cache context by cache ID.
|
protected GridCacheContext<K,V> |
GridCacheManagerAdapter.context() |
GridCacheContext<K,V> |
GridCacheAdapter.context() |
GridCacheContext<K,V> |
IgniteInternalCache.context() |
GridCacheContext<K,V> |
IgniteCacheProxyImpl.context() |
GridCacheContext<K,V> |
GatewayProtectedCacheProxy.context() |
GridCacheContext<K,V> |
IgniteCacheProxy.context() |
GridCacheContext<K,V> |
GridCacheProxyImpl.context() |
<K,V> GridCacheContext<K,V> |
GridCacheEntryEx.context() |
<K,V> GridCacheContext<K,V> |
GridCacheMapEntry.context() |
GridCacheContext<K,V> |
IgniteCacheProxyImpl.context0() |
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,
@Nullable Object key0,
@Nullable Object res,
@Nullable 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,
@Nullable MvccSnapshot mvccSnapshot,
Boolean dataPageScanEnabled) |
<K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>> |
IgniteCacheOffheapManagerImpl.cacheEntriesIterator(GridCacheContext cctx,
boolean primary,
boolean backup,
AffinityTopologyVersion topVer,
boolean keepBinary,
@Nullable MvccSnapshot mvccSnapshot,
Boolean dataPageScanEnabled) |
static void |
GridCacheUtils.checkStore(GridCacheContext<?,?> ctx)
Checks that cache store is present.
|
int |
IgniteCacheOffheapManager.CacheDataStore.cleanup(GridCacheContext cctx,
@Nullable List<MvccLinkAwareSearchRow> cleanupRows) |
int |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cleanup(GridCacheContext cctx,
@Nullable 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 @Nullable GridCacheUtils.BackupPostProcessingClosure |
GridCacheUtils.createBackupPostProcessingClosure(AffinityTopologyVersion topVer,
IgniteLogger log,
GridCacheContext cctx,
@Nullable KeyCacheObject key,
@Nullable 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,
@Nullable CacheDataRow oldRow) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
protected @Nullable GridCacheConcurrentMap.CacheMapHolder |
GridCacheLocalConcurrentMap.entriesMap(GridCacheContext cctx) |
protected abstract @Nullable GridCacheConcurrentMap.CacheMapHolder |
GridCacheConcurrentMapImpl.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 |
CacheEntryPredicate.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheInvokeDirectResult.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicateAdapter.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
GridCacheReturn.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntrySerializablePredicate.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicateContainsValue.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEvictionEntry.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.finishUnmarshalCacheObjects(@Nullable Collection<? extends CacheObject> col,
GridCacheContext ctx,
ClassLoader ldr) |
void |
GridCacheMessage.finishUnmarshalCacheObjects(@Nullable List<? extends CacheObject> col,
GridCacheContext ctx,
ClassLoader ldr) |
@Nullable GridCacheMapEntry |
GridCacheConcurrentMap.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
@Nullable GridCacheMapEntry |
GridCacheConcurrentMapImpl.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
@Nullable GridCacheMapEntry |
GridNoStorageCacheMap.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
void |
GridCacheContextInfo.initCacheContext(GridCacheContext<K,V> cctx)
Set real cache context in case cache has been fully initted and start.
|
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 @Nullable List<byte[]> |
GridCacheMessage.marshalCollection(@Nullable Collection<?> col,
GridCacheContext ctx) |
protected @Nullable byte[][] |
GridCacheMessage.marshalInvokeArguments(@Nullable Object[] args,
GridCacheContext ctx) |
void |
CacheInvokeDirectResult.marshalResult(GridCacheContext ctx)
Converts the entry processor unprepared result to a cache object instance.
|
void |
GridCacheReturn.marshalResult(GridCacheContext ctx)
Converts entry processor invokation results to cache object instances.
|
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.
|
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccApplyHistoryIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
List<GridCacheMvccEntryInfo> hist)
Tries to apply entry history.
|
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccApplyHistoryIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
List<GridCacheMvccEntryInfo> hist)
Tries to apply entry history.
|
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,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccLock(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccLock(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
@Nullable CacheDataRow |
IgniteCacheOffheapManager.mvccRead(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
@Nullable CacheDataRow |
IgniteCacheOffheapManagerImpl.mvccRead(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccRemove(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot,
@Nullable CacheEntryPredicate filter,
boolean primary,
boolean needHistory,
boolean needOldVal,
boolean retVal) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccRemove(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot,
@Nullable 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) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
@Nullable CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHist,
boolean noCreate,
boolean needOldVal,
boolean retVal,
boolean keepBinary) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
@Nullable CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
boolean retVal,
boolean keepBinary) |
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
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 |
CacheEntryPredicate.prepareMarshal(GridCacheContext ctx) |
void |
CacheInvokeDirectResult.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicateAdapter.prepareMarshal(GridCacheContext ctx) |
void |
GridCacheReturn.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntrySerializablePredicate.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicateContainsValue.prepareMarshal(GridCacheContext ctx) |
void |
CacheEvictionEntry.prepareMarshal(GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareMarshalCacheObject(CacheObject obj,
GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareMarshalCacheObjects(@Nullable Collection<? extends CacheObject> col,
GridCacheContext ctx) |
void |
GridCacheMessage.prepareMarshalCacheObjects(@Nullable List<? extends CacheObject> col,
GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareObject(@Nullable Object o,
GridCacheContext ctx) |
protected GridCacheMapEntry |
GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(@Nullable GridCacheConcurrentMap.CacheMapHolder hld,
GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean skipReserve) |
GridCacheMapEntry |
GridCacheConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean skipReserve) |
GridCacheMapEntry |
GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean skipReserve) |
GridCacheMapEntry |
GridNoStorageCacheMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean skipReserve) |
@Nullable CacheDataRow |
IgniteCacheOffheapManager.read(GridCacheContext cctx,
KeyCacheObject key) |
@Nullable 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> |
GridCachePreloaderAdapter.request(GridCacheContext ctx,
Collection<KeyCacheObject> keys,
AffinityTopologyVersion topVer)
Requests that preloader sends the request for the key.
|
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,
GridNearAtomicAbstractUpdateRequest req,
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.
|
GridCacheReturn |
GridCacheReturn.set(GridCacheContext cctx,
@Nullable CacheObject cacheObj,
boolean success,
boolean keepBinary,
@Nullable ClassLoader ldr) |
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(@Nullable 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,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManager.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManager.CacheDataStore.updateTxState(GridCacheContext cctx,
CacheSearchRow row) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.updateTxState(GridCacheContext cctx,
CacheSearchRow row) |
static <T> T |
GridCacheUtils.value(@Nullable CacheObject cacheObj,
GridCacheContext ctx,
boolean cpy) |
GridCacheReturn |
GridCacheReturn.value(GridCacheContext cctx,
CacheObject v,
boolean keepBinary,
@Nullable ClassLoader ldr) |
@Nullable 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 |
|---|---|
@Nullable CacheObject |
CacheObjectBinaryProcessorImpl.prepareForCache(@Nullable CacheObject obj,
GridCacheContext cctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
KeyCacheObject |
CacheObjectBinaryProcessorImpl.toCacheKeyObject(CacheObjectContext ctx,
@Nullable GridCacheContext cctx,
Object obj,
boolean userObj) |
protected KeyCacheObject |
CacheObjectBinaryProcessorImpl.toCacheKeyObject0(CacheObjectContext ctx,
@Nullable 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 |
GridDhtTxRemote.addWrite(GridCacheContext cacheCtx,
GridCacheOperation op,
IgniteTxKey key,
@Nullable CacheObject val,
@Nullable Collection<T2<javax.cache.processor.EntryProcessor<Object,Object,Object>,Object[]>> entryProcessors,
long ttl,
boolean skipStore,
boolean keepBinary) |
@Nullable 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,
@Nullable CacheEntryPredicate[] filter0) |
protected @Nullable byte[][] |
GridInvokeValue.marshalInvokeArguments(@Nullable Object[] args,
GridCacheContext ctx) |
void |
GridInvokeValue.prepareMarshal(GridCacheContext ctx)
Marshalls invoke value.
|
GridCacheMapEntry |
GridCachePartitionedConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean skipReserve) |
protected boolean |
GridDhtTxRemote.updateNearCache(GridCacheContext cacheCtx,
KeyCacheObject key,
AffinityTopologyVersion topVer)
Checks whether near cache should be updated.
|
protected boolean |
GridDhtTxLocal.updateNearCache(GridCacheContext cacheCtx,
KeyCacheObject key,
AffinityTopologyVersion topVer)
Checks whether near cache should be updated.
|
@Nullable CacheInvalidStateException |
GridDhtTopologyFuture.validateCache(GridCacheContext cctx,
boolean recovery,
boolean read,
@Nullable Object key,
@Nullable Collection<?> keys)
Returns error is cache topology is not valid.
|
@Nullable CacheInvalidStateException |
GridDhtTopologyFutureAdapter.validateCache(GridCacheContext cctx,
boolean recovery,
boolean read,
@Nullable Object key,
@Nullable 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,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
@Nullable 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,
@NotNull AffinityTopologyVersion topVer,
@Nullable UUID subjId,
int taskNameHash,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean recovery,
boolean addReaders,
@Nullable String txLbl,
MvccSnapshot mvccSnapshot) |
GridDhtGetSingleFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
KeyCacheObject key,
boolean addRdr,
boolean readThrough,
@NotNull AffinityTopologyVersion topVer,
@Nullable UUID subjId,
int taskNameHash,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean recovery,
@Nullable String txLbl,
@Nullable MvccSnapshot mvccSnapshot) |
GridDhtLockFuture(GridCacheContext<?,?> cctx,
UUID nearNodeId,
GridCacheVersion nearLockVer,
@NotNull 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,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
@Nullable CacheEntryPredicate filter,
boolean keepBinary) |
GridDhtTxEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
Collection<Object> rows,
EnlistOperation op,
@Nullable CacheEntryPredicate filter,
boolean needRes,
boolean keepBinary)
Constructor.
|
GridDhtTxQueryAbstractEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
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,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
boolean recovery,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
@Nullable String txLbl,
@Nullable MvccSnapshot mvccSnapshot,
ClusterNode affNode) |
GridPartitionedSingleGetFuture(GridCacheContext cctx,
KeyCacheObject key,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean forcePrimary,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
boolean recovery,
String txLbl,
@Nullable 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,
@Nullable Object[] invokeArgs,
boolean retval,
boolean rawRetval,
@Nullable 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,
@Nullable Object val,
@Nullable Object[] invokeArgs,
boolean retval,
boolean rawRetval,
@Nullable 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,
@Nullable Collection<?> vals,
@Nullable Object[] invokeArgs,
@Nullable Collection<GridCacheDrInfo> conflictPutVals,
@Nullable Collection<GridCacheVersion> conflictRmvVals,
boolean retval,
boolean rawRetval,
@Nullable 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,
@Nullable 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 |
|---|---|
protected IgniteCacheExpiryPolicy |
GridNearTxLocal.accessPolicy(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys) |
protected IgniteCacheExpiryPolicy |
GridNearTxLocal.accessPolicy(GridCacheContext ctx,
IgniteTxKey key,
@Nullable 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,
@Nullable GridCacheVersion drVer,
boolean skipStore,
boolean keepBinary) |
void |
GridNearLockRequest.addKeyBytes(KeyCacheObject key,
boolean retVal,
@Nullable 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,
@Nullable AffinityTopologyVersion entryTopVer,
Collection<KeyCacheObject> keys,
boolean deserializeBinary,
boolean skipVals,
boolean keepCacheObjects,
boolean skipStore,
boolean recovery,
boolean readRepair,
boolean needVer) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.invokeAsync(GridCacheContext cacheCtx,
@Nullable AffinityTopologyVersion entryTopVer,
K key,
javax.cache.processor.EntryProcessor<K,V,Object> entryProcessor,
Object... invokeArgs) |
<K,V,T> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.invokeAsync(GridCacheContext cacheCtx,
@Nullable AffinityTopologyVersion entryTopVer,
@Nullable 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,
@Nullable 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,
@Nullable AffinityTopologyVersion entryTopVer,
K key,
V val,
boolean retval,
CacheEntryPredicate filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.removeAllAsync(GridCacheContext cacheCtx,
@Nullable 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) |
| Constructor and Description |
|---|
GridNearAtomicCache(GridCacheContext<K,V> ctx) |
GridNearCacheAdapter(GridCacheContext<K,V> ctx) |
GridNearCacheEntry(GridCacheContext ctx,
KeyCacheObject key) |
GridNearGetFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
@Nullable IgniteTxLocalEx tx,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
boolean recovery) |
GridNearLockFuture(GridCacheContext<?,?> cctx,
Collection<KeyCacheObject> keys,
@Nullable 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) |
GridNearTxAbstractEnlistFuture(GridCacheContext<?,?> cctx,
GridNearTxLocal tx,
long timeout,
@Nullable IgniteReducer<T,T> rdc) |
GridNearTxEnlistFuture(GridCacheContext<?,?> cctx,
GridNearTxLocal tx,
long timeout,
UpdateSourceIterator<?> it,
int batchSize,
boolean sequential,
@Nullable CacheEntryPredicate filter,
boolean needRes,
boolean keepBinary) |
GridNearTxQueryAbstractEnlistFuture(GridCacheContext<?,?> cctx,
GridNearTxLocal tx,
long timeout) |
GridNearTxQueryEnlistFuture(GridCacheContext<?,?> cctx,
GridNearTxLocal tx,
int[] cacheIds,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
long timeout) |
GridNearTxQueryResultsEnlistFuture(GridCacheContext<?,?> cctx,
GridNearTxLocal tx,
long timeout,
UpdateSourceIterator<?> it,
int batchSize,
boolean sequential) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<KeyCacheObject,EntryGetResult> |
GridNearReadRepairAbstractFuture.ctx
Context.
|
| Constructor and Description |
|---|
GridNearReadRepairAbstractFuture(AffinityTopologyVersion topVer,
GridCacheContext<KeyCacheObject,EntryGetResult> ctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
IgniteInternalTx tx)
Creates a new instance of GridNearReadRepairAbstractFuture.
|
GridNearReadRepairCheckOnlyFuture(GridCacheContext ctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
IgniteInternalTx tx)
Creates a new instance of GridNearReadRepairCheckOnlyFuture.
|
GridNearReadRepairFuture(AffinityTopologyVersion topVer,
GridCacheContext ctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
IgniteInternalTx tx)
Creates a new instance of GridNearReadRepairFuture.
|
| 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 |
MvccQueryTrackerImpl.context() |
GridCacheContext |
StaticMvccQueryTracker.context() |
| Modifier and Type | Method and Description |
|---|---|
Map<UUID,CacheContinuousQueryListener> |
MvccCachingManager.continuousQueryListeners(GridCacheContext ctx0,
@Nullable IgniteInternalTx tx) |
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,
DataPageIO dataIo,
long pageAddr,
int itemId,
int pageSize) |
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 opCntrWithHints,
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 @NotNull MvccQueryTracker |
MvccUtils.mvccTracker(GridCacheContext cctx,
boolean autoStartTx)
Initialises MVCC filter and returns MVCC query tracker if needed.
|
static @NotNull MvccQueryTracker |
MvccUtils.mvccTracker(GridCacheContext cctx,
GridNearTxLocal tx)
Initialises MVCC filter and returns MVCC query tracker if needed.
|
void |
MvccProcessor.onCacheStop(GridCacheContext cctx)
Cache stop callback.
|
void |
MvccProcessorImpl.onCacheStop(GridCacheContext cctx)
Cache stop callback.
|
static byte |
MvccUtils.state(GridCacheContext cctx,
long mvccCrd,
long mvccCntr,
int mvccOpCntr) |
static GridNearTxLocal |
MvccUtils.txStart(GridCacheContext cctx,
long timeout) |
static IgniteTxUnexpectedStateCheckedException |
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> |
MvccProcessor.waitForLock(GridCacheContext cctx,
MvccVersion waiterVer,
MvccVersion blockerVer)
Stands in the lock wait queue for the current lock holder.
|
IgniteInternalFuture<Void> |
MvccProcessorImpl.waitForLock(GridCacheContext cctx,
MvccVersion waiterVer,
MvccVersion blockerVer)
Stands in the lock wait queue for the current lock holder.
|
| Constructor and Description |
|---|
MvccQueryTrackerImpl(GridCacheContext cctx) |
StaticMvccQueryTracker(GridCacheContext cctx,
MvccSnapshot snapshot) |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCacheContext> |
GridCacheDatabaseSharedManager.forceRebuildIndexes(Collection<GridCacheContext> contexts)
Initiate an asynchronous forced index rebuild for caches.
|
Collection<GridCacheContext> |
IgniteCacheDatabaseSharedManager.forceRebuildIndexes(Collection<GridCacheContext> contexts)
Initiate an asynchronous forced index rebuild for caches.
|
| Modifier and Type | Method and Description |
|---|---|
int |
GridCacheOffheapManager.GridCacheDataStore.cleanup(GridCacheContext cctx,
@Nullable List<MvccLinkAwareSearchRow> cleanupRows) |
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable 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.
|
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccApplyHistoryIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
List<GridCacheMvccEntryInfo> hist)
Tries to apply entry history.
|
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,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
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) |
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,
boolean keepBinary) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
int |
GridCacheOffheapManager.GridCacheDataStore.purgeExpired(GridCacheContext cctx,
IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c,
long throttlingTimeout,
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,
@Nullable CacheDataRow oldRow) |
void |
GridCacheOffheapManager.GridCacheDataStore.updateTxState(GridCacheContext cctx,
CacheSearchRow row) |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCacheContext> |
GridCacheDatabaseSharedManager.forceRebuildIndexes(Collection<GridCacheContext> contexts)
Initiate an asynchronous forced index rebuild for caches.
|
Collection<GridCacheContext> |
IgniteCacheDatabaseSharedManager.forceRebuildIndexes(Collection<GridCacheContext> contexts)
Initiate an asynchronous forced index rebuild for caches.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheSnapshotManager.onCacheStop(GridCacheContext<?,?> cctx,
boolean destroy)
Deprecated.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<K,V> |
GridCacheQueryFutureAdapter.cctx
Cache context.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheContext |
GridCacheQueryManager.ScanQueryIterator.cacheContext() |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheContinuousQueryManager.closeBackupUpdateCountersGaps(GridCacheContext cctx,
int part,
AffinityTopologyVersion topVer,
GridLongList gaps)
For cache updates in shared cache group need notify others caches CQ listeners
that generated counter should be skipped.
|
@Nullable CounterSkipContext |
CacheContinuousQueryListener.skipUpdateCounter(GridCacheContext cctx,
@Nullable 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() |
@Nullable GridCacheContext |
IgniteTxState.singleCacheContext(GridCacheSharedContext cctx) |
@Nullable GridCacheContext |
IgniteTxRemoteStateAdapter.singleCacheContext(GridCacheSharedContext cctx) |
@Nullable GridCacheContext |
IgniteTxStateImpl.singleCacheContext(GridCacheSharedContext cctx) |
@Nullable GridCacheContext |
IgniteTxImplicitSingleStateImpl.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,
@Nullable 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 |
IgniteTxState.addActiveCache(GridCacheContext cacheCtx,
boolean recovery,
IgniteTxAdapter tx) |
void |
IgniteTxRemoteStateAdapter.addActiveCache(GridCacheContext cctx,
boolean recovery,
IgniteTxAdapter tx) |
void |
IgniteTxStateImpl.addActiveCache(GridCacheContext cacheCtx,
boolean recovery,
IgniteTxAdapter tx) |
void |
IgniteTxImplicitSingleStateImpl.addActiveCache(GridCacheContext ctx,
boolean recovery,
IgniteTxAdapter tx) |
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,
@Nullable GridCacheContext sysCacheCtx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean storeEnabled,
Boolean mvccOp,
int txSize,
@Nullable String lb,
boolean tracingEnabled) |
<T extends IgniteInternalTx> |
IgniteTxManager.onCreated(@Nullable GridCacheContext cacheCtx,
T tx) |
protected void |
IgniteTxLocalStateAdapter.onTxEnd(GridCacheContext cacheCtx,
IgniteInternalTx tx,
boolean commit) |
@Nullable GridTuple<CacheObject> |
IgniteTxLocalAdapter.peek(GridCacheContext cacheCtx,
boolean failFast,
KeyCacheObject key) |
@Nullable 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) |
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,
@Nullable 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,
@Nullable CacheEntryPredicate filter,
boolean primary,
boolean lockOnly,
boolean needHist,
boolean fastUpdate,
boolean needOldVal,
boolean needPrevValue) |
| 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 |
|---|---|
@Nullable CacheObject |
IgniteCacheObjectProcessor.prepareForCache(@Nullable CacheObject obj,
GridCacheContext cctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
KeyCacheObject |
IgniteCacheObjectProcessor.toCacheKeyObject(CacheObjectContext ctx,
@Nullable GridCacheContext cctx,
Object obj,
boolean userObj) |
@Nullable Object |
IgniteCacheObjectProcessor.unwrapTemporary(GridCacheContext ctx,
@Nullable 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 |
|---|---|
void |
PlatformCacheEntryFilter.cacheContext(GridCacheContext cctx)
Sets the cache context.
|
void |
PlatformCacheEntryFilterImpl.cacheContext(GridCacheContext cctx)
Sets the cache context.
|
void |
PlatformCacheManager.start(GridCacheContext cctx)
Starts manager.
|
| 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,
@Nullable GridCacheContext<?,?> cctx,
IgniteOutClosureX<R> clo,
boolean complete) |
UpdateSourceIterator<?> |
GridQueryProcessor.executeUpdateOnDataNodeTransactional(GridCacheContext<?,?> cctx,
int[] cacheIds,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
int timeout,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot,
GridQueryCancel cancel)
Execute update on DHT node (i.e. when it is possible to execute and update on all nodes independently).
|
UpdateSourceIterator<?> |
GridQueryIndexing.executeUpdateOnDataNodeTransactional(GridCacheContext<?,?> cctx,
int[] ids,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
int timeout,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot,
GridQueryCancel cancel) |
boolean |
GridQueryIndexing.initCacheContext(GridCacheContext ctx)
Initialize table's cache context created for not started cache.
|
void |
GridQueryProcessor.markAsRebuildNeeded(GridCacheContext cctx,
boolean val)
Mark that for given cache index should/would be rebuilt.
|
void |
GridQueryIndexing.markAsRebuildNeeded(GridCacheContext cctx,
boolean val)
Mark as rebuild needed for the given cache.
|
void |
GridQueryProcessor.onFinishRebuildIndexes(GridCacheContext cacheCtx)
Callback on finish of rebuild cache indexes.
|
void |
GridQueryProcessor.onStartRebuildIndexes(GridCacheContext cacheCtx)
Callback on start of rebuild cache indexes.
|
<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(@Nullable GridCacheContext<?,?> cctx,
SqlFieldsQuery qry,
SqlClientContext cliCtx,
boolean keepBinary,
boolean failOnMultipleStmts)
Query SQL fields.
|
List<FieldsQueryCursor<List<?>>> |
GridQueryProcessor.querySqlFields(@Nullable GridCacheContext<?,?> cctx,
SqlFieldsQuery qry,
SqlClientContext cliCtx,
boolean keepBinary,
boolean failOnMultipleStmts,
GridCacheQueryType qryType,
@Nullable GridQueryCancel cancel)
Query SQL fields.
|
List<FieldsQueryCursor<List<?>>> |
GridQueryProcessor.querySqlFields(@Nullable GridCacheContext<?,?> cctx,
SqlFieldsQuery qry,
SqlClientContext cliCtx,
boolean keepBinary,
boolean failOnMultipleStmts,
@Nullable GridQueryCancel cancel)
Query SQL fields.
|
boolean |
GridQueryProcessor.rebuildIndexesCompleted(GridCacheContext cacheCtx)
Check if rebuilding of indexes for the cache has been completed.
|
IgniteInternalFuture<?> |
GridQueryProcessor.rebuildIndexesFromHash(GridCacheContext cctx,
boolean force)
Rebuilds indexes for provided caches from corresponding hash indexes.
|
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,
@Nullable CacheDataRow prevRow,
boolean prevRowAvailable) |
void |
GridQueryIndexing.store(GridCacheContext cctx,
GridQueryTypeDescriptor type,
CacheDataRow row,
CacheDataRow prevRow,
boolean prevRowAvailable)
Updates index.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IndexRebuildStateStorage.onStartRebuildIndexes(GridCacheContext cacheCtx)
Callback on start of rebuild cache indexes.
|
| Constructor and Description |
|---|
SchemaIndexCachePartitionWorker(GridCacheContext cctx,
GridDhtLocalPartition locPart,
AtomicBoolean stop,
@Nullable SchemaIndexOperationCancellationToken cancel,
SchemaIndexCacheVisitorClosure clo,
GridFutureAdapter<SchemaIndexCacheStat> fut,
AtomicInteger partsCnt)
Constructor.
|
SchemaIndexCacheVisitorImpl(GridCacheContext cctx,
@Nullable SchemaIndexOperationCancellationToken cancel,
GridFutureAdapter<Void> buildIdxFut)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
static BaselineTopology |
IgniteUtils.getBaselineTopology(@NotNull GridCacheContext cctx) |
| Constructor and Description |
|---|
IndexListInfoContainer(GridCacheContext ctx,
String idxName,
Collection<String> colsNames,
String tblName) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.0 Release Date : September 11 2021