| Package | Description |
|---|---|
| org.apache.ignite.internal.pagemem.store | |
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.distributed.dht | |
| org.apache.ignite.internal.processors.cache.distributed.dht.preloader | |
| org.apache.ignite.internal.processors.cache.distributed.dht.topology | |
| org.apache.ignite.internal.processors.cache.mvcc | |
| org.apache.ignite.internal.processors.cache.persistence |
This package contain cache with persistence implementation.
|
| org.apache.ignite.internal.processors.cache.persistence.checkpoint | |
| org.apache.ignite.internal.processors.cache.persistence.file | |
| org.apache.ignite.internal.processors.cache.persistence.snapshot | |
| org.apache.ignite.internal.processors.cache.tree | |
| org.apache.ignite.internal.processors.cache.tree.mvcc.data | |
| org.apache.ignite.internal.processors.cache.verify |
| 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 |
PartitionUpdateCounterTrackingImpl.grp |
protected CacheGroupContext |
IgniteCacheOffheapManagerImpl.grp |
protected CacheGroupContext |
GridCachePreloaderAdapter.grp |
| Modifier and Type | Method and Description |
|---|---|
@Nullable CacheGroupContext |
GridCacheProcessor.cacheGroup(int grpId) |
CacheGroupContext |
PartitionUpdateCounterTrackingImpl.context() |
CacheGroupContext |
PartitionUpdateCounterDebugWrapper.context() |
CacheGroupContext |
PartitionUpdateCounter.context() |
CacheGroupContext |
PartitionUpdateCounterVolatileImpl.context() |
CacheGroupContext |
GridCacheContext.group() |
| Modifier and Type | Method and Description |
|---|---|
Collection<CacheGroupContext> |
GridCacheProcessor.cacheGroups() |
| Modifier and Type | Method and Description |
|---|---|
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 |
|---|---|
void |
ClientCacheDhtTopologyFuture.validate(CacheGroupContext grp,
Collection<ClusterNode> topNodes) |
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) |
| 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) |
void |
PartitionsEvictManager.evictPartitionAsync(CacheGroupContext grp,
GridDhtLocalPartition part,
org.apache.ignite.internal.processors.cache.distributed.dht.topology.PartitionsEvictManager.EvictReason reason)
Adds partition to eviction queue and starts eviction process if permit
available.
|
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 |
|---|---|
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 |
GridCacheDatabaseSharedManager.onCacheGroupsStopped(Collection<IgniteBiTuple<CacheGroupContext,Boolean>> stoppedGrps) |
void |
IgniteCacheDatabaseSharedManager.onCacheGroupsStopped(Collection<IgniteBiTuple<CacheGroupContext,Boolean>> stoppedGrps) |
| Constructor and Description |
|---|
RowStore(CacheGroupContext grp,
FreeList freeList) |
| Modifier and Type | Method and Description |
|---|---|
void |
PartitionDestroyQueue.addDestroyRequest(@Nullable CacheGroupContext grpCtx,
int grpId,
int partId) |
| 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,
PageLockListener lockLsnr) |
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,
PageLockListener lockLsnr) |
| 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 |
|---|---|
static void |
IdleVerifyUtility.checkPartitionsPageCrcSum(FilePageStore pageStore,
CacheGroupContext grpCtx,
int partId,
byte pageType)
Checks CRC sum of pages with
pageType page type stored in partiion with partId id and assosiated
with cache group. |
static void |
IdleVerifyUtility.checkPartitionsPageCrcSum(@Nullable FilePageStoreManager pageStoreMgr,
CacheGroupContext grpCtx,
int partId,
byte pageType)
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.0 Release Date : October 15 2020