org.apache.ignite.internal.processors.cache.persistence

Class GridCacheDatabaseSharedManager

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter

org.apache.ignite.internal.processors.cache.persistence.IgniteCacheDatabaseSharedManager

org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager

All Implemented Interfaces:

GridCacheSharedManager, CheckpointLockStateChecker, CheckpointWriteProgressSupplier, IgniteChangeGlobalStateSupport

public class GridCacheDatabaseSharedManager
extends IgniteCacheDatabaseSharedManager
implements CheckpointWriteProgressSupplier

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GridCacheDatabaseSharedManager.Checkpoint
class	GridCacheDatabaseSharedManager.Checkpointer Checkpointer object is used for notification on checkpoint begin, predicate is GridCacheDatabaseSharedManager.Checkpointer.scheduledCp.nextCpTs - now > 0 .
static class	GridCacheDatabaseSharedManager.FileLockHolder
static class	GridCacheDatabaseSharedManager.RestoreBinaryState Restore memory context.
static class	GridCacheDatabaseSharedManager.RestoreLogicalState Restore logical state context.
static class	GridCacheDatabaseSharedManager.RestoreStateContext Abstract class for create restore context.

Field Summary

Fields

Modifier and Type	Field and Description
static Pattern	CP_FILE_NAME_PATTERN Checkpoint file name pattern.
static String	IGNITE_PDS_CHECKPOINT_TEST_SKIP_SYNC
static String	METASTORE_DATA_REGION_NAME MemoryPolicyConfiguration name reserved for meta store.
static String	NODE_STARTED_FILE_NAME_SUFFIX Node started file suffix.

Fields inherited from class org.apache.ignite.internal.processors.cache.persistence.IgniteCacheDatabaseSharedManager

dataRegionMap, dfltDataRegion, freeListMap, memMetricsMap, SYSTEM_DATA_REGION_NAME

Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter

cctx, diagnosticLog, log

Constructor Summary

Constructors

Constructor and Description
GridCacheDatabaseSharedManager(GridKernalContext ctx)

Method Summary

Modifier and Type	Method and Description
void	addCheckpointListener(DbCheckpointListener lsnr)
void	applyUpdatesOnRecovery(WALIterator it, IgnitePredicate<IgniteBiTuple<WALPointer,WALRecord>> recPredicate, IgnitePredicate<DataEntry> entryPredicate, Map<T2<Integer,Integer>,T2<Integer,Long>> partStates) Apply update from some iterator and with specific filters.
boolean	beforeExchange(GridDhtPartitionsExchangeFuture fut)
void	cancelOrWaitPartitionDestroy(int grpId, int partId) Cancels or wait for partition destroy.
protected void	checkPageSize(DataStorageConfiguration memCfg)
File	checkpointDirectory()
CheckpointHistory	checkpointHistory()
boolean	checkpointLockIsHeldByThread()
void	checkpointReadLock() Gets the checkpoint read lock.
long	checkpointReadLockTimeout() Timeout for checkpoint read lock acquisition.
void	checkpointReadLockTimeout(long val) Sets timeout for checkpoint read lock acquisition.
void	checkpointReadUnlock() Releases the checkpoint read lock.
protected void	checkRegionEvictionProperties(DataRegionConfiguration regCfg, DataStorageConfiguration dbCfg)
void	cleanupCheckpointDirectory() Cleanup checkpoint directory.
void	cleanupTempCheckpointDirectory() Cleanup checkpoint directory from all temporary files.
CheckpointEntry	createCheckPointEntry(long cpTs, WALPointer ptr, UUID cpId, CheckpointRecord rec, CheckpointEntryType type)
protected PageMemory	createPageMemory(DirectMemoryProvider memProvider, DataStorageConfiguration memCfg, DataRegionConfiguration plcCfg, DataRegionMetricsImpl memMetrics, boolean trackable) Creates PageMemory with given size and memory provider.
int	currentCheckpointPagesCount()
IgniteInternalFuture<Void>	enableCheckpoints(boolean enable) For test use only.
AtomicInteger	evictedPagesCntr()
CheckpointFuture	forceCheckpoint(String reason) Allows to wait checkpoint finished.
protected IgniteOutClosure<Long>	freeSpaceProvider(DataRegionConfiguration dataRegCfg) Closure that can be used to compute fill factor for provided data region.
GridCacheDatabaseSharedManager.Checkpointer	getCheckpointer()
IgniteInternalFuture	indexRebuildFuture(int cacheId)
protected void	initDataRegions0(DataStorageConfiguration memCfg)
boolean	isCheckpointInapplicableForWalRebalance(Long cpTs, int grpId) Checks that checkpoint with timestamp cpTs is inapplicable as start point for WAL rebalance for given group grpId.
void	lastCheckpointInapplicableForWalRebalance(int grpId) Set last checkpoint as inapplicable for WAL rebalance for given group grpId.
WALPointer	lastCheckpointMarkWalPointer()
MetaStorage	metaStorage()
List<T2<Long,WALPointer>>	nodeStartedPointers() Collects memory recovery pointers from node started files.
void	notifyMetaStorageSubscribersOnReadyForRead() Notifies MetastorageLifecycleListener that MetaStorage is ready for read.
void	onActivate(GridKernalContext ctx) Called when cluster performing activation.
void	onCacheGroupsStopped(Collection<IgniteBiTuple<CacheGroupContext,Boolean>> stoppedGrps)
void	onDeActivate(GridKernalContext kctx) Called when cluster performing deactivation.
protected void	onKernalStop0(boolean cancel)
void	onStateRestored() Called when all partitions have been fully restored and pre-created on node start.
void	onWalTruncated(WALPointer highBound) Wal truncate callBack.
DataStorageMetrics	persistentStoreMetrics()
DataStorageMetricsImpl	persistentStoreMetricsImpl()
void	readCheckpointAndRestoreMemory(List<DynamicCacheDescriptor> cachesToStart)
void	rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)
void	releaseHistoryForExchange() Release reserved update history.
void	releaseHistoryForPreloading() Release reserved update history.
void	removeCheckpointListener(DbCheckpointListener lsnr)
Map<Integer,Map<Integer,Long>>	reserveHistoryForExchange() Reserve update history for exchange.
boolean	reserveHistoryForPreloading(int grpId, int partId, long cntr) Reserve update history for preloading.
void	schedulePartitionDestroy(int grpId, int partId) Adds given partition to checkpointer destroy queue.
void	setThreadBuf(ThreadLocal<ByteBuffer> threadBuf) Replace thread local with buffers.
protected void	start0()
protected void	stop0(boolean cancel)
AtomicInteger	syncedPagesCounter()
void	waitForCheckpoint(String reason) Waits until current state is checkpointed.
IgniteInternalFuture	wakeupForCheckpoint(String reason)
boolean	walEnabled(int grpId, boolean local)
void	walEnabled(int grpId, boolean enabled, boolean local) Marks cache group as with disabled WAL.
protected DirectMemoryProvider	wrapMetricsMemoryProvider(DirectMemoryProvider memoryProvider0, DataRegionMetricsImpl memMetrics)
void	writeCheckpointEntry(ByteBuffer entryBuf, CheckpointEntry cp, CheckpointEntryType type) Writes checkpoint entry buffer entryBuf to specified checkpoint file with 2-phase protocol.
AtomicInteger	writtenPagesCounter() Counter for written checkpoint pages.

Methods inherited from class org.apache.ignite.internal.processors.cache.persistence.IgniteCacheDatabaseSharedManager

addDataRegion, buildAllocPath, buildPath, createPageEvictionTracker, dataRegion, dataRegions, dumpStatistics, ensureFreeSpace, freeList, getDatabaseListeners, initDataRegions, initPageMemoryDataStructures, memoryMetrics, memoryMetrics, pageSize, prepareCachesStop, reuseList, setPageSize, systemDateRegionName

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter

context, isStopping, kernalStartInfo, kernalStopInfo, log, onDisconnected, onKernalStop, onReconnected, printMemoryStats, start, startInfo, stop, stopInfo, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

IGNITE_PDS_CHECKPOINT_TEST_SKIP_SYNC

public static final String IGNITE_PDS_CHECKPOINT_TEST_SKIP_SYNC

See Also:

Constant Field Values

METASTORE_DATA_REGION_NAME

public static final String METASTORE_DATA_REGION_NAME

MemoryPolicyConfiguration name reserved for meta store.

See Also:

Constant Field Values

CP_FILE_NAME_PATTERN

public static final Pattern CP_FILE_NAME_PATTERN

Checkpoint file name pattern.

NODE_STARTED_FILE_NAME_SUFFIX

public static final String NODE_STARTED_FILE_NAME_SUFFIX

Node started file suffix.

See Also:

Constant Field Values

Constructor Detail

GridCacheDatabaseSharedManager

public GridCacheDatabaseSharedManager(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

getCheckpointer

public GridCacheDatabaseSharedManager.Checkpointer getCheckpointer()

enableCheckpoints

public IgniteInternalFuture<Void> enableCheckpoints(boolean enable)

For test use only.

initDataRegions0

protected void initDataRegions0(DataStorageConfiguration memCfg)
                         throws IgniteCheckedException

Overrides:

initDataRegions0 in class IgniteCacheDatabaseSharedManager

Parameters:

memCfg - Database config.

Throws:

IgniteCheckedException - If failed to initialize swap path.

start0

protected void start0()
               throws IgniteCheckedException

Overrides:

start0 in class IgniteCacheDatabaseSharedManager

Throws:

IgniteCheckedException - If failed.

cleanupTempCheckpointDirectory

public void cleanupTempCheckpointDirectory()
                                    throws IgniteCheckedException

Cleanup checkpoint directory from all temporary files.

Overrides:

cleanupTempCheckpointDirectory in class IgniteCacheDatabaseSharedManager

Throws:

IgniteCheckedException

cleanupCheckpointDirectory

public void cleanupCheckpointDirectory()
                                throws IgniteCheckedException

Cleanup checkpoint directory.

Overrides:

cleanupCheckpointDirectory in class IgniteCacheDatabaseSharedManager

Throws:

IgniteCheckedException

onActivate

public void onActivate(GridKernalContext ctx)
                throws IgniteCheckedException

Called when cluster performing activation.

Specified by:

onActivate in interface IgniteChangeGlobalStateSupport

Overrides:

onActivate in class IgniteCacheDatabaseSharedManager

Parameters:

ctx - Kernal context.

Throws:

IgniteCheckedException - If failed.

onDeActivate

public void onDeActivate(GridKernalContext kctx)

Called when cluster performing deactivation.

Specified by:

onDeActivate in interface IgniteChangeGlobalStateSupport

Overrides:

onDeActivate in class IgniteCacheDatabaseSharedManager

Parameters:

kctx - Kernal context.

freeSpaceProvider

protected IgniteOutClosure<Long> freeSpaceProvider(DataRegionConfiguration dataRegCfg)

Closure that can be used to compute fill factor for provided data region.

Overrides:

freeSpaceProvider in class IgniteCacheDatabaseSharedManager

Parameters:

dataRegCfg - Data region configuration.

Returns:

Closure.

readCheckpointAndRestoreMemory

public void readCheckpointAndRestoreMemory(List<DynamicCacheDescriptor> cachesToStart)
                                    throws IgniteCheckedException

Overrides:

readCheckpointAndRestoreMemory in class IgniteCacheDatabaseSharedManager

Parameters:

cachesToStart - Started caches.

Throws:

IgniteCheckedException - If failed.

nodeStartedPointers

public List<T2<Long,WALPointer>> nodeStartedPointers()
                                              throws IgniteCheckedException

Collects memory recovery pointers from node started files. See nodeStart(WALPointer). Each pointer associated with timestamp extracted from file. Tuples are sorted by timestamp.

Returns:

Sorted list of tuples (node started timestamp, memory recovery pointer).

Throws:

IgniteCheckedException - If failed.

onKernalStop0

protected void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridCacheSharedManagerAdapter

Parameters:

cancel - Cancel flag.

stop0

protected void stop0(boolean cancel)

Overrides:

stop0 in class IgniteCacheDatabaseSharedManager

Parameters:

cancel - Cancel flag.

createPageMemory

protected PageMemory createPageMemory(DirectMemoryProvider memProvider,
                                      DataStorageConfiguration memCfg,
                                      DataRegionConfiguration plcCfg,
                                      DataRegionMetricsImpl memMetrics,
                                      boolean trackable)

Creates PageMemory with given size and memory provider.

Overrides:

createPageMemory in class IgniteCacheDatabaseSharedManager

Parameters:

memProvider - Memory provider.

memCfg - Memory configuartion.

plcCfg - data region configuration.

memMetrics - DataRegionMetrics to collect memory usage metrics.

Returns:

PageMemory instance.

wrapMetricsMemoryProvider

protected DirectMemoryProvider wrapMetricsMemoryProvider(DirectMemoryProvider memoryProvider0,
                                                         DataRegionMetricsImpl memMetrics)

Overrides:

wrapMetricsMemoryProvider in class IgniteCacheDatabaseSharedManager

Parameters:

memoryProvider0 - Memory provider.

memMetrics - Memory metrics.

Returns:

Wrapped memory provider.

checkRegionEvictionProperties

protected void checkRegionEvictionProperties(DataRegionConfiguration regCfg,
                                             DataStorageConfiguration dbCfg)
                                      throws IgniteCheckedException

Overrides:

checkRegionEvictionProperties in class IgniteCacheDatabaseSharedManager

Parameters:

regCfg - DataRegionConfiguration to validate.

dbCfg - Memory configuration.

Throws:

IgniteCheckedException - If config is invalid.

checkPageSize

protected void checkPageSize(DataStorageConfiguration memCfg)

Overrides:

checkPageSize in class IgniteCacheDatabaseSharedManager

Parameters:

memCfg - Memory config.

beforeExchange

public boolean beforeExchange(GridDhtPartitionsExchangeFuture fut)
                       throws IgniteCheckedException

Overrides:

beforeExchange in class IgniteCacheDatabaseSharedManager

Parameters:

fut - Before exchange for the given discovery event.

Returns:

True if partitions have been restored from persistent storage.

Throws:

IgniteCheckedException

rebuildIndexesIfNeeded

public void rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)

Overrides:

rebuildIndexesIfNeeded in class IgniteCacheDatabaseSharedManager

Parameters:

fut - Partition exchange future.

indexRebuildFuture

@Nullable
public IgniteInternalFuture indexRebuildFuture(int cacheId)

Overrides:

indexRebuildFuture in class IgniteCacheDatabaseSharedManager

Returns:

Future that will be completed when indexes for given cache are restored.

onCacheGroupsStopped

public void onCacheGroupsStopped(Collection<IgniteBiTuple<CacheGroupContext,Boolean>> stoppedGrps)

Overrides:

onCacheGroupsStopped in class IgniteCacheDatabaseSharedManager

Parameters:

stoppedGrps - A collection of tuples (cache group, destroy flag).

checkpointReadLock

public void checkpointReadLock()

Gets the checkpoint read lock. While this lock is held, checkpoint thread will not acquireSnapshotWorker memory state.

Overrides:

checkpointReadLock in class IgniteCacheDatabaseSharedManager

Throws:

IgniteException - If failed.

checkpointLockIsHeldByThread

public boolean checkpointLockIsHeldByThread()

Specified by:

checkpointLockIsHeldByThread in interface CheckpointLockStateChecker

Overrides:

checkpointLockIsHeldByThread in class IgniteCacheDatabaseSharedManager

Returns:

true if checkpoint lock is held by current thread

checkpointReadUnlock

public void checkpointReadUnlock()

Releases the checkpoint read lock.

Overrides:

checkpointReadUnlock in class IgniteCacheDatabaseSharedManager

onStateRestored

public void onStateRestored()
                     throws IgniteCheckedException

Called when all partitions have been fully restored and pre-created on node start. Starts checkpointing process and initiates first checkpoint.

Overrides:

onStateRestored in class IgniteCacheDatabaseSharedManager

Throws:

IgniteCheckedException - If first checkpoint has failed.

reserveHistoryForExchange

public Map<Integer,Map<Integer,Long>> reserveHistoryForExchange()

Reserve update history for exchange.

Overrides:

reserveHistoryForExchange in class IgniteCacheDatabaseSharedManager

Returns:

Reserved update counters per cache and partition.

releaseHistoryForExchange

public void releaseHistoryForExchange()

Release reserved update history.

Overrides:

releaseHistoryForExchange in class IgniteCacheDatabaseSharedManager

reserveHistoryForPreloading

public boolean reserveHistoryForPreloading(int grpId,
                                           int partId,
                                           long cntr)

Reserve update history for preloading.

Overrides:

reserveHistoryForPreloading in class IgniteCacheDatabaseSharedManager

Parameters:

grpId - Cache group ID.

partId - Partition Id.

cntr - Update counter.

Returns:

True if successfully reserved.

releaseHistoryForPreloading

public void releaseHistoryForPreloading()

Release reserved update history.

Overrides:

releaseHistoryForPreloading in class IgniteCacheDatabaseSharedManager

wakeupForCheckpoint

@Nullable
public IgniteInternalFuture wakeupForCheckpoint(String reason)

Overrides:

wakeupForCheckpoint in class IgniteCacheDatabaseSharedManager

waitForCheckpoint

public void waitForCheckpoint(String reason)
                       throws IgniteCheckedException

Waits until current state is checkpointed.

Overrides:

waitForCheckpoint in class IgniteCacheDatabaseSharedManager

Throws:

IgniteCheckedException - If failed.

forceCheckpoint

public CheckpointFuture forceCheckpoint(String reason)

Allows to wait checkpoint finished.

Overrides:

forceCheckpoint in class IgniteCacheDatabaseSharedManager

Parameters:

reason - Reason.

lastCheckpointMarkWalPointer

public WALPointer lastCheckpointMarkWalPointer()

Overrides:

lastCheckpointMarkWalPointer in class IgniteCacheDatabaseSharedManager

Returns:

Last checkpoint mark WAL pointer.

checkpointDirectory

public File checkpointDirectory()

Returns:

Checkpoint directory.

addCheckpointListener

public void addCheckpointListener(DbCheckpointListener lsnr)

Parameters:

lsnr - Listener.

removeCheckpointListener

public void removeCheckpointListener(DbCheckpointListener lsnr)

Parameters:

lsnr - Listener.

applyUpdatesOnRecovery

public void applyUpdatesOnRecovery(@Nullable
                                   WALIterator it,
                                   IgnitePredicate<IgniteBiTuple<WALPointer,WALRecord>> recPredicate,
                                   IgnitePredicate<DataEntry> entryPredicate,
                                   Map<T2<Integer,Integer>,T2<Integer,Long>> partStates)
                            throws IgniteCheckedException

Apply update from some iterator and with specific filters.

Parameters:

it - WalIterator.

recPredicate - Wal record filter.

entryPredicate - Entry filter.

partStates - Partition to restore state.

Throws:

IgniteCheckedException

onWalTruncated

public void onWalTruncated(WALPointer highBound)
                    throws IgniteCheckedException

Wal truncate callBack.

Parameters:

highBound - WALPointer.

Throws:

IgniteCheckedException

writeCheckpointEntry

public void writeCheckpointEntry(ByteBuffer entryBuf,
                                 CheckpointEntry cp,
                                 CheckpointEntryType type)
                          throws StorageException

Writes checkpoint entry buffer entryBuf to specified checkpoint file with 2-phase protocol.

Parameters:

entryBuf - Checkpoint entry buffer to write.

cp - Checkpoint entry.

type - Checkpoint entry type.

Throws:

StorageException - If failed to write checkpoint entry.

writtenPagesCounter

public AtomicInteger writtenPagesCounter()

Counter for written checkpoint pages. Not null only if checkpoint is running.

Specified by:

writtenPagesCounter in interface CheckpointWriteProgressSupplier

syncedPagesCounter

public AtomicInteger syncedPagesCounter()

Specified by:

syncedPagesCounter in interface CheckpointWriteProgressSupplier

Returns:

Counter for fsynced checkpoint pages. Not null only if checkpoint is running.

evictedPagesCntr

public AtomicInteger evictedPagesCntr()

Specified by:

evictedPagesCntr in interface CheckpointWriteProgressSupplier

Returns:

Counter for evicted pages during current checkpoint. Not null only if checkpoint is running.

currentCheckpointPagesCount

public int currentCheckpointPagesCount()

Specified by:

currentCheckpointPagesCount in interface CheckpointWriteProgressSupplier

Returns:

Number of pages in current checkpoint. If checkpoint is not running, returns 0.

setThreadBuf

public void setThreadBuf(ThreadLocal<ByteBuffer> threadBuf)

Replace thread local with buffers. Thread local should provide direct buffer with one page in length.

Parameters:

threadBuf - new thread-local with buffers for the checkpoint threads.

createCheckPointEntry

public CheckpointEntry createCheckPointEntry(long cpTs,
                                             WALPointer ptr,
                                             UUID cpId,
                                             @Nullable
                                             CheckpointRecord rec,
                                             CheckpointEntryType type)

Parameters:

cpTs - Checkpoint timestamp.

ptr - Wal pointer of checkpoint.

cpId - Checkpoint ID.

rec - Checkpoint record.

type - Checkpoint type.

Returns:

Checkpoint entry.

checkpointHistory

@Nullable
public CheckpointHistory checkpointHistory()

Returns:

Checkpoint history.

schedulePartitionDestroy

public void schedulePartitionDestroy(int grpId,
                                     int partId)

Adds given partition to checkpointer destroy queue.

Parameters:

grpId - Group ID.

partId - Partition ID.

cancelOrWaitPartitionDestroy

public void cancelOrWaitPartitionDestroy(int grpId,
                                         int partId)
                                  throws IgniteCheckedException

Cancels or wait for partition destroy.

Parameters:

grpId - Group ID.

partId - Partition ID.

Throws:

IgniteCheckedException - If failed.

checkpointReadLockTimeout

public long checkpointReadLockTimeout()

Timeout for checkpoint read lock acquisition.

Overrides:

checkpointReadLockTimeout in class IgniteCacheDatabaseSharedManager

Returns:

Timeout for checkpoint read lock acquisition in milliseconds.

checkpointReadLockTimeout

public void checkpointReadLockTimeout(long val)

Sets timeout for checkpoint read lock acquisition.

Overrides:

checkpointReadLockTimeout in class IgniteCacheDatabaseSharedManager

Parameters:

val - New timeout in milliseconds, non-positive value denotes infinite timeout.

persistentStoreMetrics

public DataStorageMetrics persistentStoreMetrics()

Overrides:

persistentStoreMetrics in class IgniteCacheDatabaseSharedManager

Returns:

DataStorageMetrics if persistence is enabled or null otherwise.

persistentStoreMetricsImpl

public DataStorageMetricsImpl persistentStoreMetricsImpl()

metaStorage

public MetaStorage metaStorage()

Overrides:

metaStorage in class IgniteCacheDatabaseSharedManager

Returns:

MetaStorage

notifyMetaStorageSubscribersOnReadyForRead

public void notifyMetaStorageSubscribersOnReadyForRead()
                                                throws IgniteCheckedException

Notifies MetastorageLifecycleListener that MetaStorage is ready for read. This method is called when all processors and managers have already started and right before discovery manager.

Overrides:

notifyMetaStorageSubscribersOnReadyForRead in class IgniteCacheDatabaseSharedManager

Throws:

IgniteCheckedException - If failed.

walEnabled

public boolean walEnabled(int grpId,
                          boolean local)

Overrides:

walEnabled in class IgniteCacheDatabaseSharedManager

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.

Overrides:

walEnabled in class IgniteCacheDatabaseSharedManager

Parameters:

grpId - Group id.

enabled - flag.

isCheckpointInapplicableForWalRebalance

public boolean isCheckpointInapplicableForWalRebalance(Long cpTs,
                                                       int grpId)
                                                throws IgniteCheckedException

Checks that checkpoint with timestamp cpTs is inapplicable as start point for WAL rebalance for given group grpId.

Parameters:

cpTs - Checkpoint timestamp.

grpId - Group ID.

Returns:

true if checkpoint cpTs is inapplicable as start point for WAL rebalance for grpId.

Throws:

IgniteCheckedException - If failed to check.

lastCheckpointInapplicableForWalRebalance

public void lastCheckpointInapplicableForWalRebalance(int grpId)

Set last checkpoint as inapplicable for WAL rebalance for given group grpId.

Overrides:

lastCheckpointInapplicableForWalRebalance in class IgniteCacheDatabaseSharedManager

Parameters:

grpId - Group ID.