Class IgniteCacheDatabaseSharedManager
- java.lang.Object
-
- org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter
-
- org.apache.ignite.internal.processors.cache.persistence.IgniteCacheDatabaseSharedManager
-
- All Implemented Interfaces:
GridCacheSharedManager,CheckpointLockStateChecker,IgniteChangeGlobalStateSupport
- Direct Known Subclasses:
GridCacheDatabaseSharedManager
public class IgniteCacheDatabaseSharedManager extends GridCacheSharedManagerAdapter implements IgniteChangeGlobalStateSupport, CheckpointLockStateChecker
-
-
Field Summary
Fields Modifier and Type Field Description static StringDATA_REGION_PAGE_LIST_VIEWSystem view name for page lists.static StringDATA_REGION_PAGE_LIST_VIEW_DESCSystem view description for page lists.protected Map<String,DataRegion>dataRegionMapprotected booleandataRegionsInitializedprotected DataRegiondfltDataRegionprotected DataStorageMetricsImpldsMetricsData storege metrics.protected Map<String,CacheFreeList>freeListMapstatic Set<String>INTERNAL_DATA_REGION_NAMESDataRegionConfiguration names reserved for various internal needs.static StringPAGE_TS_HISTOGRAM_VIEWSystem view name for pages timestamp histogram.static StringPAGE_TS_HISTOGRAM_VIEW_DESCSystem view description for pages timestamp histogram.protected booleanreuseMemoryTrueto reuse memory on deactive.static StringSYSTEM_DATA_REGION_NAMEDataRegionConfiguration name reserved for internal caches.-
Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter
cctx, diagnosticLog, log
-
-
Constructor Summary
Constructors Constructor Description IgniteCacheDatabaseSharedManager(GridKernalContext ctx)
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description DataRegionaddDataRegion(DataStorageConfiguration dataStorageCfg, DataRegionConfiguration dataRegionCfg, boolean trackable)protected DataRegionaddDataRegion(DataStorageConfiguration dataStorageCfg, DataRegionConfiguration dataRegionCfg, boolean trackable, PageReadWriteManager pmPageMgr)voidbeforeExchange(GridDhtPartitionsExchangeFuture discoEvt)protected @Nullable FilebuildAllocPath(DataRegionConfiguration plc)Builds allocation path for memory mapped file to be used with PageMemory.protected FilebuildPath(String path, String consId)protected voidcheckPageSize(DataStorageConfiguration memCfg)booleancheckpointLockIsHeldByThread()voidcheckpointReadLock()No-op for non-persistent storage.longcheckpointReadLockTimeout()voidcheckpointReadLockTimeout(long val)No-op for non-persistent storage.voidcheckpointReadUnlock()No-op for non-persistent storage.protected voidcheckRegionEvictionProperties(DataRegionConfiguration regCfg, DataStorageConfiguration dbCfg)voidcleanupCheckpointDirectory()Clean checkpoint directoryCheckpointMarkersStorage.cpDir.voidcleanupRestoredCaches()Method will perform cleanup cache page memory and each cache partition store.voidcleanupTempCheckpointDirectory()No-op for non-persistent storage.protected PageEvictionTrackercreatePageEvictionTracker(DataRegionConfiguration plc, PageMemory pageMem)protected PageMemorycreatePageMemory(DirectMemoryProvider memProvider, DataStorageConfiguration dsCfg, DataRegionConfiguration regCfg, DataRegionMetricsImpl regMetrics, boolean trackable, PageReadWriteManager pageMgr)Creates PageMemory with given size and memory provider.@Nullable DataRegiondataRegion(@Nullable String memPlcName)Getting data region by name.protected DataRegionMetricsProviderdataRegionMetricsProvider(DataRegionConfiguration dataRegCfg)Provide that can be used to compute some metrics for provided data region.Collection<DataRegion>dataRegions()Getting registered data regions.DataStorageMetricsImpldataStorageMetricsImpl()voiddumpStatistics(IgniteLogger log)voidensureFreeSpace(DataRegion memPlc)SeeGridCacheMapEntry#ensureFreeSpace()voidensureFreeSpaceForInsert(DataRegion region, int dataRowSize)Checks that the givenregionhas enough space for putting a new entry.@Nullable CheckpointProgressforceCheckpoint(String reason)Schedule a new checkpoint.<R> @Nullable CheckpointProgressforceNewCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)Schedule a new checkpoint.Collection<GridCacheContext>forceRebuildIndexes(Collection<GridCacheContext> contexts)Initiate an asynchronous forced index rebuild for caches.FreeListfreeList(String memPlcName)protected IgniteOutClosure<Long>freeSpaceProvider(DataRegionConfiguration dataRegCfg)Deprecated.usedataRegionMetricsProvider(DataRegionConfiguration)instead.protected List<DatabaseLifecycleListener>getDatabaseListeners(GridKernalContext kctx)protected voidinitAndStartRegions(DataStorageConfiguration cfg)protected voidinitDataRegions(DataStorageConfiguration memCfg)protected voidinitDataRegions0(DataStorageConfiguration memCfg)protected voidinitPageMemoryDataStructures(DataStorageConfiguration dbCfg)voidlastCheckpointInapplicableForWalRebalance(int grpId)Marks last checkpoint as inapplicable for WAL rebalance for given groupgrpId.@Nullable WALPointerlastCheckpointMarkWalPointer()WALPointerlatestWalPointerReservedForPreloading()Returns the latest WAL pointer that reserved for preloading ornull.Collection<DataRegionMetrics>memoryMetrics()@Nullable DataRegionMetricsmemoryMetrics(String dataRegionName)MetaStoragemetaStorage()voidnotifyMetaStorageSubscribersOnReadyForRead()NotifiesMetastorageLifecycleListenerthatMetaStorageis ready for read.voidonActivate(GridKernalContext kctx)Called when cluster performing activation.voidonCacheGroupsStopped(Collection<IgniteBiTuple<CacheGroupContext,Boolean>> stoppedGrps)voidonDeActivate(GridKernalContext kctx)Called when cluster performing deactivation.voidonStateRestored(AffinityTopologyVersion topVer)Called when all partitions have been fully restored and pre-created on node start.voidonWalTruncated(WALPointer highBound)Wal truncate callback.intpageSize()voidprepareCachesStop()Needed action before any cache will stopvoidrebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)voidreleaseHistoryForExchange()Release reserved update history.voidreleaseHistoryForPreloading()Release reserved update history.Map<Integer,Map<Integer,Long>>reserveHistoryForExchange()Reserve update history for exchange.booleanreserveHistoryForPreloading(Map<T2<Integer,Integer>,Long> reservationMap)Reserve update history for preloading.ReuseListreuseList(String memPlcName)protected voidsetPageSize(int pageSize)Method for fake (standalone) context initialization.protected voidstart0()voidstartMemoryRestore(GridKernalContext kctx, TimeBag startTimer)Perform memory restore beforeGridDiscoveryManagerstart.protected voidstop0(boolean cancel)booleansupportsMemoryReuse(DataRegionConfiguration plcCfg)StringsystemDateRegionName()voidwaitForCheckpoint(String reason)Waits until current state is checkpointed.<R> voidwaitForCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)Waits until current state is checkpointed and execution listeners after finish.@Nullable IgniteInternalFuturewakeupForCheckpoint(String reason)booleanwalEnabled(int grpId, boolean local)voidwalEnabled(int grpId, boolean enabled, boolean local)Marks cache group as with disabled WAL.-
Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter
context, isStopping, kernalStartInfo, kernalStopInfo, onDisconnected, onKernalStart, onKernalStart0, onKernalStop, onKernalStop0, onReconnected, printMemoryStats, start, startInfo, stop, stopInfo, toString
-
-
-
-
Field Detail
-
SYSTEM_DATA_REGION_NAME
public static final String SYSTEM_DATA_REGION_NAME
DataRegionConfiguration name reserved for internal caches.- See Also:
- Constant Field Values
-
INTERNAL_DATA_REGION_NAMES
public static Set<String> INTERNAL_DATA_REGION_NAMES
DataRegionConfiguration names reserved for various internal needs.
-
DATA_REGION_PAGE_LIST_VIEW
public static final String DATA_REGION_PAGE_LIST_VIEW
System view name for page lists.- See Also:
- Constant Field Values
-
DATA_REGION_PAGE_LIST_VIEW_DESC
public static final String DATA_REGION_PAGE_LIST_VIEW_DESC
System view description for page lists.- See Also:
- Constant Field Values
-
PAGE_TS_HISTOGRAM_VIEW
public static final String PAGE_TS_HISTOGRAM_VIEW
System view name for pages timestamp histogram.- See Also:
- Constant Field Values
-
PAGE_TS_HISTOGRAM_VIEW_DESC
public static final String PAGE_TS_HISTOGRAM_VIEW_DESC
System view description for pages timestamp histogram.- See Also:
- Constant Field Values
-
reuseMemory
protected final boolean reuseMemory
Trueto reuse memory on deactive.
-
dataRegionMap
protected final Map<String,DataRegion> dataRegionMap
-
dataRegionsInitialized
protected volatile boolean dataRegionsInitialized
-
dfltDataRegion
protected DataRegion dfltDataRegion
-
freeListMap
protected Map<String,CacheFreeList> freeListMap
-
dsMetrics
protected final DataStorageMetricsImpl dsMetrics
Data storege metrics.
-
-
Constructor Detail
-
IgniteCacheDatabaseSharedManager
public IgniteCacheDatabaseSharedManager(GridKernalContext ctx)
- Parameters:
ctx- Kernal context.
-
-
Method Detail
-
start0
protected void start0() throws IgniteCheckedException- Overrides:
start0in classGridCacheSharedManagerAdapter- Throws:
IgniteCheckedException- If failed.
-
initPageMemoryDataStructures
protected void initPageMemoryDataStructures(DataStorageConfiguration dbCfg) throws IgniteCheckedException
- Parameters:
dbCfg- Database config.- Throws:
IgniteCheckedException- If failed.
-
pageSize
public int pageSize()
- Returns:
- Size of page used for PageMemory regions.
-
initDataRegions
protected void initDataRegions(DataStorageConfiguration memCfg) throws IgniteCheckedException
- Parameters:
memCfg- Database config.- Throws:
IgniteCheckedException- If failed to initialize swap path.
-
initDataRegions0
protected void initDataRegions0(DataStorageConfiguration memCfg) throws IgniteCheckedException
- Parameters:
memCfg- Database config.- Throws:
IgniteCheckedException- If failed to initialize swap path.
-
getDatabaseListeners
protected List<DatabaseLifecycleListener> getDatabaseListeners(GridKernalContext kctx)
- Parameters:
kctx- Kernal context.- Returns:
- Database lifecycle listeners.
-
addDataRegion
public DataRegion addDataRegion(DataStorageConfiguration dataStorageCfg, DataRegionConfiguration dataRegionCfg, boolean trackable) throws IgniteCheckedException
- Parameters:
dataStorageCfg- Database config.dataRegionCfg- Data region config.- Throws:
IgniteCheckedException- If failed to initialize swap path.
-
addDataRegion
protected DataRegion addDataRegion(DataStorageConfiguration dataStorageCfg, DataRegionConfiguration dataRegionCfg, boolean trackable, PageReadWriteManager pmPageMgr) throws IgniteCheckedException
- Parameters:
dataStorageCfg- Database config.dataRegionCfg- Data region config.pmPageMgr- Page manager.- Throws:
IgniteCheckedException- If failed to initialize swap path.
-
freeSpaceProvider
@Deprecated protected IgniteOutClosure<Long> freeSpaceProvider(DataRegionConfiguration dataRegCfg)
Deprecated.usedataRegionMetricsProvider(DataRegionConfiguration)instead.Closure that can be used to compute fill factor for provided data region.- Parameters:
dataRegCfg- Data region configuration.- Returns:
- Closure.
-
dataRegionMetricsProvider
protected DataRegionMetricsProvider dataRegionMetricsProvider(DataRegionConfiguration dataRegCfg)
Provide that can be used to compute some metrics for provided data region.- Parameters:
dataRegCfg- Data region configuration.- Returns:
- DataRegionMetricsProvider.
-
checkPageSize
protected void checkPageSize(DataStorageConfiguration memCfg)
- Parameters:
memCfg- Memory config.
-
checkRegionEvictionProperties
protected void checkRegionEvictionProperties(DataRegionConfiguration regCfg, DataStorageConfiguration dbCfg) throws IgniteCheckedException
- Parameters:
regCfg- DataRegionConfiguration to validate.dbCfg- Memory configuration.- Throws:
IgniteCheckedException- If config is invalid.
-
dumpStatistics
public void dumpStatistics(IgniteLogger log)
- Parameters:
log- Logger.
-
dataRegions
public Collection<DataRegion> dataRegions()
Getting registered data regions.- Returns:
- Collection of all configured
policies.
-
memoryMetrics
public Collection<DataRegionMetrics> memoryMetrics()
- Returns:
- DataRegionMetrics for all MemoryPolicies configured in Ignite instance.
-
dataStorageMetricsImpl
public DataStorageMetricsImpl dataStorageMetricsImpl()
- Returns:
- Data storage metrics implementation.
-
memoryMetrics
@Nullable public @Nullable DataRegionMetrics memoryMetrics(String dataRegionName)
- Parameters:
dataRegionName- Name ofDataRegionto obtainDataRegionMetricsfor.- Returns:
DataRegionMetricssnapshot for specifiedDataRegionornullif noDataRegionis configured for specified name.
-
dataRegion
@Nullable public @Nullable DataRegion dataRegion(@Nullable @Nullable String memPlcName) throws IgniteCheckedException
Getting data region by name.- Parameters:
memPlcName- Data region name. In case ofnull, default data region will be returned.- Returns:
DataRegioninstance associated with a givenDataRegionConfiguration, ornullif there are no registered data regions.- Throws:
IgniteCheckedException- in case of request for unknown DataRegion.
-
freeList
public FreeList freeList(String memPlcName)
- Parameters:
memPlcName- DataRegionConfiguration name.- Returns:
FreeListinstance associated with a givenDataRegionConfiguration.
-
reuseList
public ReuseList reuseList(String memPlcName)
- Parameters:
memPlcName- DataRegionConfiguration name.- Returns:
ReuseListinstance associated with a givenDataRegionConfiguration.
-
stop0
protected void stop0(boolean cancel)
- Overrides:
stop0in classGridCacheSharedManagerAdapter- Parameters:
cancel- Cancel flag.
-
checkpointLockIsHeldByThread
public boolean checkpointLockIsHeldByThread()
- Specified by:
checkpointLockIsHeldByThreadin interfaceCheckpointLockStateChecker- Returns:
- true if checkpoint lock is held by current thread
-
checkpointReadLock
public void checkpointReadLock()
No-op for non-persistent storage.
-
checkpointReadUnlock
public void checkpointReadUnlock()
No-op for non-persistent storage.
-
checkpointReadLockTimeout
public long checkpointReadLockTimeout()
- Returns:
0for non-persistent storage.
-
checkpointReadLockTimeout
public void checkpointReadLockTimeout(long val)
No-op for non-persistent storage.
-
cleanupRestoredCaches
public void cleanupRestoredCaches()
Method will perform cleanup cache page memory and each cache partition store.
-
cleanupCheckpointDirectory
public void cleanupCheckpointDirectory() throws IgniteCheckedExceptionClean checkpoint directoryCheckpointMarkersStorage.cpDir. The operation is necessary when local node joined to baseline topology with different consistentId.- Throws:
IgniteCheckedException
-
cleanupTempCheckpointDirectory
public void cleanupTempCheckpointDirectory() throws IgniteCheckedExceptionNo-op for non-persistent storage.- Throws:
IgniteCheckedException
-
wakeupForCheckpoint
@Nullable public @Nullable IgniteInternalFuture wakeupForCheckpoint(String reason)
-
lastCheckpointMarkWalPointer
@Nullable public @Nullable WALPointer lastCheckpointMarkWalPointer()
- Returns:
- Last checkpoint mark WAL pointer.
-
forceCheckpoint
@Nullable public @Nullable CheckpointProgress forceCheckpoint(String reason)
Schedule a new checkpoint.Note: if a checkpoint is already running and the locks have not been taken yet, then a new checkpoint will not be forced.
- Parameters:
reason- Reason.
-
forceNewCheckpoint
@Nullable public <R> @Nullable CheckpointProgress forceNewCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)
Schedule a new checkpoint.- Parameters:
reason- Reason.lsnr- Listener which will be called on scheduled checkpoint finish.
-
waitForCheckpoint
public void waitForCheckpoint(String reason) throws IgniteCheckedException
Waits until current state is checkpointed.- Throws:
IgniteCheckedException- If failed.
-
waitForCheckpoint
public <R> void waitForCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr) throws IgniteCheckedException
Waits until current state is checkpointed and execution listeners after finish.- Parameters:
reason- Reason for checkpoint wakeup if it would be required.lsnr- Listeners which should be called in checkpoint thread after current checkpoint finished.- Throws:
IgniteCheckedException- If failed.
-
beforeExchange
public void beforeExchange(GridDhtPartitionsExchangeFuture discoEvt) throws IgniteCheckedException
- Parameters:
discoEvt- Before exchange for the given discovery event.- Throws:
IgniteCheckedException
-
startMemoryRestore
public void startMemoryRestore(GridKernalContext kctx, TimeBag startTimer) throws IgniteCheckedException
Perform memory restore beforeGridDiscoveryManagerstart.- Parameters:
kctx- Current kernal context.startTimer- Holder of start time of stages.- Throws:
IgniteCheckedException- If fails.
-
onStateRestored
public void onStateRestored(AffinityTopologyVersion topVer) throws IgniteCheckedException
Called when all partitions have been fully restored and pre-created on node start.- Throws:
IgniteCheckedException- If failed.
-
rebuildIndexesIfNeeded
public void rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)
- Parameters:
fut- Partition exchange future.
-
forceRebuildIndexes
public Collection<GridCacheContext> forceRebuildIndexes(Collection<GridCacheContext> contexts)
Initiate an asynchronous forced index rebuild for caches.- Parameters:
contexts- Cache contexts.- Returns:
- Cache contexts for which index rebuilding is not initiated by this call because they are already in the process of rebuilding.
-
prepareCachesStop
public void prepareCachesStop()
Needed action before any cache will stop
-
onCacheGroupsStopped
public void onCacheGroupsStopped(Collection<IgniteBiTuple<CacheGroupContext,Boolean>> stoppedGrps)
- Parameters:
stoppedGrps- A collection of tuples (cache group, destroy flag).
-
reserveHistoryForExchange
public Map<Integer,Map<Integer,Long>> reserveHistoryForExchange()
Reserve update history for exchange.- Returns:
- Reserved update counters per cache and partition.
-
releaseHistoryForExchange
public void releaseHistoryForExchange()
Release reserved update history.
-
reserveHistoryForPreloading
public boolean reserveHistoryForPreloading(Map<T2<Integer,Integer>,Long> reservationMap)
Reserve update history for preloading.- Parameters:
reservationMap- Map contains of counters for partitions of groups.- Returns:
- True if successfully reserved.
-
releaseHistoryForPreloading
public void releaseHistoryForPreloading()
Release reserved update history.
-
latestWalPointerReservedForPreloading
public WALPointer latestWalPointerReservedForPreloading()
Returns the latest WAL pointer that reserved for preloading ornull.- Returns:
- WAL pointer or
nullif nothing reserved.
-
ensureFreeSpaceForInsert
public void ensureFreeSpaceForInsert(DataRegion region, int dataRowSize) throws IgniteOutOfMemoryException
Checks that the givenregionhas enough space for putting a new entry. This method makes sense then and only then the data region is not persistedDataRegionConfiguration.isPersistenceEnabled()and page eviction is disabledDataPageEvictionMode.DISABLED. The non-persistent region should reserve a number of pages to support a free listAbstractFreeList. For example, removing a row from underlying store may require allocating a new data page in order to move a tracked page from one bucket to another one which does not have a free space for a new stripe. SeeAbstractFreeList.removeDataRowByLink(long, org.apache.ignite.internal.metric.IoStatisticsHolder). Therefore, inserting a new entry should be prevented in case of some threshold is exceeded.- Parameters:
region- Data region to be checked.dataRowSize- Size of data row to be inserted.- Throws:
IgniteOutOfMemoryException- In case of the given data region does not have enough free space for putting a new entry.
-
ensureFreeSpace
public void ensureFreeSpace(DataRegion memPlc) throws IgniteCheckedException
SeeGridCacheMapEntry#ensureFreeSpace()- Parameters:
memPlc- data region.- Throws:
IgniteCheckedException
-
supportsMemoryReuse
public boolean supportsMemoryReuse(DataRegionConfiguration plcCfg)
- Parameters:
plcCfg- Policy config.- Returns:
Trueif policy supports memory reuse.
-
createPageEvictionTracker
protected PageEvictionTracker createPageEvictionTracker(DataRegionConfiguration plc, PageMemory pageMem)
- Parameters:
plc- data region Configuration.pageMem- Page memory.
-
buildAllocPath
@Nullable protected @Nullable File buildAllocPath(DataRegionConfiguration plc) throws IgniteCheckedException
Builds allocation path for memory mapped file to be used with PageMemory.- Parameters:
plc- DataRegionConfiguration.- Throws:
IgniteCheckedException- If resolving swap directory fails.
-
createPageMemory
protected PageMemory createPageMemory(DirectMemoryProvider memProvider, DataStorageConfiguration dsCfg, DataRegionConfiguration regCfg, DataRegionMetricsImpl regMetrics, boolean trackable, PageReadWriteManager pageMgr)
Creates PageMemory with given size and memory provider.- Parameters:
memProvider- Direct memory provider.dsCfg- Data storage configuration.regCfg- Data region configuration.regMetrics- Data region metrics to collect memory usage metrics.pageMgr- Page read/write manager.- Returns:
- PageMemory instance.
-
buildPath
protected File buildPath(String path, String consId) throws IgniteCheckedException
- Parameters:
path- Path to the working directory.consId- Consistent ID of the local node.- Returns:
- DB storage path.
- Throws:
IgniteCheckedException- If resolving swap directory fails.
-
onActivate
public void onActivate(GridKernalContext kctx) throws IgniteCheckedException
Called when cluster performing activation.- Specified by:
onActivatein interfaceIgniteChangeGlobalStateSupport- Parameters:
kctx- Kernal context.- Throws:
IgniteCheckedException- If failed.
-
initAndStartRegions
protected void initAndStartRegions(DataStorageConfiguration cfg) throws IgniteCheckedException
- Parameters:
cfg- Current data storage configuration.- Throws:
IgniteCheckedException- If fails.
-
onDeActivate
public void onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.- Specified by:
onDeActivatein interfaceIgniteChangeGlobalStateSupport- Parameters:
kctx- Kernal context.
-
systemDateRegionName
public String systemDateRegionName()
- Returns:
- Name of DataRegionConfiguration for internal caches.
-
setPageSize
protected void setPageSize(int pageSize)
Method for fake (standalone) context initialization. Not to be called in production code- Parameters:
pageSize- configured page size
-
metaStorage
public MetaStorage metaStorage()
- Returns:
- MetaStorage
-
notifyMetaStorageSubscribersOnReadyForRead
public void notifyMetaStorageSubscribersOnReadyForRead() throws IgniteCheckedExceptionNotifiesMetastorageLifecycleListenerthatMetaStorageis ready for read. This method is called when all processors and managers have already started and right before discovery manager.- Throws:
IgniteCheckedException- If failed.
-
walEnabled
public boolean walEnabled(int grpId, boolean local)- Parameters:
grpId- Group ID.- Returns:
- WAL enabled flag.
-
walEnabled
public void walEnabled(int grpId, boolean enabled, boolean local)Marks cache group as with disabled WAL.- Parameters:
grpId- Group id.enabled- flag.
-
lastCheckpointInapplicableForWalRebalance
public void lastCheckpointInapplicableForWalRebalance(int grpId)
Marks last checkpoint as inapplicable for WAL rebalance for given groupgrpId.- Parameters:
grpId- Group id.
-
onWalTruncated
public void onWalTruncated(WALPointer highBound) throws IgniteCheckedException
Wal truncate callback.- Parameters:
highBound- Upper bound.- Throws:
IgniteCheckedException- If failed.
-
-