| Modifier and Type | Method and Description |
|---|---|
void |
IndexProcessor.defragment(CacheGroupContext grpCtx,
CacheGroupContext newCtx,
PageMemoryEx partPageMem,
IntMap<LinkMap> mappingByPart,
CheckpointTimeoutLock cpLock,
Runnable cancellationChecker,
IgniteThreadPoolExecutor defragmentationThreadPool)
Defragment index partition.
|
| Modifier and Type | Method and Description |
|---|---|
protected InlineIndexTree |
DurableBackgroundCleanupIndexTreeTaskV2.InlineIndexTreeFactory.create(CacheGroupContext grpCtx,
RootPage rootPage,
String treeName)
Creation of an index tree.
|
static long |
DurableBackgroundCleanupIndexTreeTaskV2.destroyIndexTrees(CacheGroupContext grpCtx,
RootPage rootPage,
String cacheName,
String treeName,
int segment)
Destroying index trees.
|
static Map<Integer,RootPage> |
DurableBackgroundCleanupIndexTreeTaskV2.findIndexRootPages(CacheGroupContext grpCtx,
String cacheName,
String treeName,
int segments)
Finding the root pages of the index.
|
static void |
DurableBackgroundCleanupIndexTreeTaskV2.renameIndexRootPages(CacheGroupContext grpCtx,
String cacheName,
String oldTreeName,
String newTreeName,
int segments)
Renaming the root index pages.
|
void |
DurableBackgroundCleanupIndexTreeTaskV2.renameIndexTrees(CacheGroupContext grpCtx)
Renames index's trees.
|
| Constructor and Description |
|---|
IndexRowCache(CacheGroupContext grpCtx,
int maxSize) |
| Modifier and Type | Method and Description |
|---|---|
void |
IndexingDefragmentation.defragment(CacheGroupContext grpCtx,
CacheGroupContext newCtx,
PageMemoryEx partPageMem,
IntMap<LinkMap> mappingByPartition,
CheckpointTimeoutLock cpLock,
Runnable cancellationChecker,
IgniteThreadPoolExecutor defragmentationThreadPool,
IgniteLogger log)
Defragment index partition.
|
| Modifier and Type | Method and Description |
|---|---|
CacheGroupContext |
InlineIndexTree.cacheGroupContext()
Getting cache group context.
|
| Constructor and Description |
|---|
InlineIndexTree(SortedIndexDefinition def,
CacheGroupContext grpCtx,
String treeName,
IgniteCacheOffheapManager offheap,
ReuseList reuseList,
PageMemory pageMemory,
PageIoResolver pageIoResolver,
long metaPageId,
boolean initNew,
int configuredInlineSize,
int maxInlineSize,
IndexKeyTypeSettings keyTypeSettings,
@Nullable IndexRowCache idxRowCache,
@Nullable IoStatisticsHolder stats,
InlineIndexRowHandlerFactory rowHndFactory,
InlineRecommender recommender)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridEncryptionManager.onCancelDestroyPartitionStore(CacheGroupContext grp,
int partId) |
void |
GridEncryptionManager.onDestroyPartitionStore(CacheGroupContext grp,
int partId) |
long[] |
CacheGroupPageScanner.pagesCount(CacheGroupContext grp)
Collect current number of pages in the specified cache group.
|
void |
GridEncryptionManager.setEncryptionState(CacheGroupContext grp,
int partId,
int idx,
int total)
Set reencryption status for partition.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgnitePageStoreManager.shutdownForCacheGroup(CacheGroupContext grp,
boolean destroy)
Callback called when a cache is stopping.
|
| Modifier and Type | Field and Description |
|---|---|
protected CacheGroupContext |
IgniteCacheOffheapManagerImpl.grp |
protected CacheGroupContext |
GridCachePreloaderAdapter.grp |
protected CacheGroupContext |
PartitionUpdateCounterTrackingImpl.grp |
| Modifier and Type | Method and Description |
|---|---|
@Nullable CacheGroupContext |
GridCacheProcessor.cacheGroup(int grpId) |
CacheGroupContext |
PartitionUpdateCounterErrorWrapper.context() |
CacheGroupContext |
PartitionUpdateCounterDebugWrapper.context() |
CacheGroupContext |
PartitionUpdateCounterTrackingImpl.context() |
CacheGroupContext |
PartitionUpdateCounterVolatileImpl.context() |
CacheGroupContext |
PartitionUpdateCounter.context() |
CacheGroupContext |
GridCacheContext.group() |
| Modifier and Type | Method and Description |
|---|---|
Collection<CacheGroupContext> |
GridCacheProcessor.cacheGroups() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridLocalConfigManager.removeCacheGroupConfigurationData(CacheGroupContext ctx)
Delete caches' configuration data files of cache group.
|
void |
IgniteCacheOffheapManagerImpl.start(GridCacheSharedContext ctx,
CacheGroupContext grp) |
void |
IgniteCacheOffheapManager.start(GridCacheSharedContext ctx,
CacheGroupContext grp) |
void |
CacheAffinitySharedManager.stopCacheGroupOnReconnect(CacheGroupContext grpCtx) |
| Modifier and Type | Method and Description |
|---|---|
GridDhtPartitionsFullMessage |
GridCachePartitionExchangeManager.createPartitionsFullMessage(boolean compress,
boolean newCntrMap,
@Nullable GridDhtPartitionExchangeId exchId,
@Nullable GridCacheVersion lastVer,
@Nullable IgniteDhtPartitionHistorySuppliersMap partHistSuppliers,
@Nullable IgniteDhtPartitionsToReloadMap partsToReload,
Collection<CacheGroupContext> grps)
Creates partitions full message for selected cache groups.
|
GridDhtPartitionsSingleMessage |
GridCachePartitionExchangeManager.createPartitionsSingleMessage(@Nullable GridDhtPartitionExchangeId exchangeId,
boolean clientOnlyExchange,
boolean sndCounters,
boolean newCntrMap,
ExchangeActions exchActions,
Collection<CacheGroupContext> grps)
Creates partitions single message for selected cache groups.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridDhtTopologyFutureAdapter.CacheGroupValidation |
GridDhtTopologyFutureAdapter.validateCacheGroup(CacheGroupContext grp,
Collection<ClusterNode> topNodes) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionsExchangeFuture.addClearingPartition(CacheGroupContext grp,
int part)
Marks a partition for clearing before rebalance.
|
boolean |
GridDhtPartitionsExchangeFuture.isClearingPartition(CacheGroupContext grp,
int part) |
void |
GridDhtPartitionsExchangeFuture.validate(CacheGroupContext grp) |
| Constructor and Description |
|---|
GridDhtPartitionDemander(CacheGroupContext grp) |
GridDhtPreloader(CacheGroupContext grp) |
| Modifier and Type | Method and Description |
|---|---|
CacheGroupContext |
GridDhtLocalPartition.group()
Returns group context.
|
| Modifier and Type | Method and Description |
|---|---|
GridDhtLocalPartition |
GridDhtPartitionTopologyImpl.PartitionFactory.create(GridCacheSharedContext ctx,
CacheGroupContext grp,
int id,
boolean recovery) |
IgniteInternalFuture<?> |
PartitionsEvictManager.evictPartitionAsync(CacheGroupContext grp,
GridDhtLocalPartition part,
GridFutureAdapter<?> finishFut)
Adds partition to eviction queue and starts eviction process if permit
available.
|
void |
PartitionsEvictManager.onCacheGroupStarted(CacheGroupContext grp)
Callback on cache group start.
|
void |
PartitionsEvictManager.onCacheGroupStopped(CacheGroupContext grp)
Stops eviction process for group.
|
| Constructor and Description |
|---|
GridDhtLocalPartition(GridCacheSharedContext ctx,
CacheGroupContext grp,
int id,
boolean recovery) |
GridDhtPartitionTopologyImpl(GridCacheSharedContext ctx,
CacheGroupContext grp) |
| Modifier and Type | Method and Description |
|---|---|
static byte |
MvccUtils.state(CacheGroupContext grp,
long mvccCrd,
long mvccCntr,
int mvccOpCntr) |
static IgniteTxUnexpectedStateCheckedException |
MvccUtils.unexpectedStateException(CacheGroupContext grp,
byte state,
long crd,
long cntr,
int opCntr) |
| Modifier and Type | Field and Description |
|---|---|
protected CacheGroupContext |
RowStore.grp |
| Modifier and Type | Method and Description |
|---|---|
GridCacheOffheapManager.GridCacheDataStore |
GridCacheOffheapManager.createGridCacheDataStore(CacheGroupContext grpCtx,
int partId,
boolean exists,
IgniteLogger log) |
long |
GridCacheDatabaseSharedManager.forGroupPageStores(CacheGroupContext gctx,
ToLongFunction<PageStore> f) |
void |
CacheDataRowAdapter.initFromDataPage(DataPageIO io,
long pageAddr,
int itemId,
@Nullable CacheGroupContext grp,
GridCacheSharedContext<?,?> sharedCtx,
PageMemory pageMem,
CacheDataRowAdapter.RowData rowData,
boolean skipVer) |
void |
CacheDataRowAdapter.initFromLink(CacheGroupContext grp,
CacheDataRowAdapter.RowData rowData)
Read row from data pages.
|
void |
CacheDataRowAdapter.initFromLink(CacheGroupContext grp,
CacheDataRowAdapter.RowData rowData,
boolean skipVer)
Read row from data pages.
|
void |
CacheDataRowAdapter.initFromLink(@Nullable CacheGroupContext grp,
GridCacheSharedContext<?,?> sharedCtx,
PageMemory pageMem,
CacheDataRowAdapter.RowData rowData,
boolean skipVer)
Read row from data pages.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheDatabaseSharedManager.onCacheGroupsStopped(Collection<IgniteBiTuple<CacheGroupContext,Boolean>> stoppedGrps) |
void |
GridCacheDatabaseSharedManager.onCacheGroupsStopped(Collection<IgniteBiTuple<CacheGroupContext,Boolean>> stoppedGrps) |
| Constructor and Description |
|---|
GridCacheDataStore(CacheGroupContext grp,
int partId,
boolean exists,
GridSpinBusyLock busyLock,
IgniteLogger log) |
RowStore(CacheGroupContext grp,
FreeList freeList) |
| Modifier and Type | Method and Description |
|---|---|
void |
PartitionDestroyQueue.addDestroyRequest(@Nullable CacheGroupContext grpCtx,
int grpId,
int partId) |
void |
CheckpointManager.schedulePartitionDestroy(@Nullable CacheGroupContext context,
int groupId,
int partId) |
void |
Checkpointer.schedulePartitionDestroy(@Nullable CacheGroupContext grpCtx,
int grpId,
int partId) |
void |
LightweightCheckpointManager.schedulePartitionDestroy(@Nullable CacheGroupContext context,
int groupId,
int partId) |
| Constructor and Description |
|---|
CheckpointManager(Function<Class<?>,IgniteLogger> logger,
String igniteInstanceName,
String checkpointThreadName,
IgniteWriteAheadLogManager wal,
WorkersRegistry workersRegistry,
DataStorageConfiguration persistenceCfg,
FilePageStoreManager pageStoreManager,
IgniteThrowableBiPredicate<Long,Integer> checkpointInapplicableChecker,
Supplier<Collection<DataRegion>> dataRegions,
Supplier<Collection<CacheGroupContext>> cacheGroupContexts,
IgniteThrowableFunction<Integer,PageMemoryEx> pageMemoryGroupResolver,
PageMemoryImpl.ThrottlingPolicy throttlingPolicy,
IgniteCacheSnapshotManager snapshotMgr,
DataStorageMetricsImpl persStoreMetrics,
LongJVMPauseDetector longJvmPauseDetector,
FailureProcessor failureProcessor,
GridCacheProcessor cacheProcessor,
Supplier<Integer> cpFreqDeviation,
Executor checkpointMapSnapshotExecutor) |
| Constructor and Description |
|---|
LinkMap(CacheGroupContext ctx,
PageMemory pageMem,
long metaPageId,
boolean initNew) |
| Modifier and Type | Method and Description |
|---|---|
void |
FilePageStoreManager.shutdownForCacheGroup(CacheGroupContext grp,
boolean destroy)
Callback called when a cache is stopping.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheSnapshotManager.onCacheGroupStop(CacheGroupContext gctx,
boolean destroy)
Deprecated.
|
boolean |
IgniteCacheSnapshotManager.partitionsAreFrozen(CacheGroupContext grp)
Deprecated.
|
| Constructor and Description |
|---|
CacheDataRowStore(CacheGroupContext grp,
FreeList freeList,
int partId) |
CacheDataTree(CacheGroupContext grp,
String name,
ReuseList reuseList,
CacheDataRowStore rowStore,
long metaPageId,
boolean initNew,
PageLockTrackerManager pageLockTrackerManager,
byte pageFlag) |
DataRow(CacheGroupContext grp,
int hash,
long link,
int part,
CacheDataRowAdapter.RowData rowData,
boolean skipVer) |
PendingEntriesTree(CacheGroupContext grp,
String name,
PageMemory pageMem,
long metaPageId,
ReuseList reuseList,
boolean initNew,
PageLockTrackerManager pageLockTrackerManager,
byte pageFlag) |
| Constructor and Description |
|---|
MvccDataRow(CacheGroupContext grp,
int hash,
long link,
int part,
CacheDataRowAdapter.RowData rowData,
long crdVer,
long mvccCntr,
int mvccOpCntr,
boolean skipVer) |
| Modifier and Type | Method and Description |
|---|---|
protected Map<CacheGroupContext,List<org.apache.ignite.internal.processors.cache.warmup.LoadAllWarmUpStrategy.LoadPartition>> |
LoadAllWarmUpStrategy.loadDataInfo(DataRegion region)
Calculation of cache groups, partitions and count of pages that can load
into data region.
|
| Constructor and Description |
|---|
LoadAllWarmUpStrategy(IgniteLogger log,
Supplier<Collection<CacheGroupContext>> grpCtxSup)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
CacheGroupContext |
IgniteStatisticsHelper.groupContext(StatisticsKey key)
Get cache group context by specified statistics key.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract VisorCacheGroupEncryptionTask.VisorSingleFieldDto<T> |
VisorCacheGroupEncryptionTask.VisorReencryptionBaseJob.run0(CacheGroupContext grp)
Executes internal logic of the job.
|
| Constructor and Description |
|---|
CacheGroupIoView(CacheGroupContext grpCtx,
MetricRegistry mreg) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.15.0 Release Date : April 25 2023