public interface CheckpointProgress
| Modifier and Type | Method and Description |
|---|---|
void |
clearCounters()
Clear cp progress counters.
|
int |
currentCheckpointPagesCount() |
void |
currentCheckpointPagesCount(int num)
Sets current checkpoint pages num to store.
|
AtomicInteger |
evictedPagesCounter() |
void |
fail(Throwable error)
Mark this checkpoint execution as failed.
|
GridFutureAdapter |
futureFor(CheckpointState state) |
PartitionDestroyQueue |
getDestroyQueue() |
void |
initCounters(int pagesSize)
Initialize all counters before checkpoint.
|
boolean |
inProgress() |
AtomicInteger |
syncedPagesCounter() |
void |
transitTo(@NotNull CheckpointState newState)
Changing checkpoint state if order of state is correct.
|
void |
updateEvictedPages(int deltha)
Update evicted pages in checkpoint;
|
void |
updateSyncedPages(int deltha)
Update synced pages in checkpoint;
|
void |
updateWrittenPages(int deltha)
Update written pages in checkpoint;
|
AtomicInteger |
writtenPagesCounter() |
boolean inProgress()
GridFutureAdapter futureFor(CheckpointState state)
void fail(Throwable error)
error - Causal error of fail.void transitTo(@NotNull
@NotNull CheckpointState newState)
newState - New checkpoint state.PartitionDestroyQueue getDestroyQueue()
AtomicInteger writtenPagesCounter()
null only if checkpoint is running.AtomicInteger syncedPagesCounter()
null only if checkpoint is running.AtomicInteger evictedPagesCounter()
null only if checkpoint is running.int currentCheckpointPagesCount()
void currentCheckpointPagesCount(int num)
num - Pages to store.void initCounters(int pagesSize)
void updateSyncedPages(int deltha)
deltha - Pages num to update.void updateWrittenPages(int deltha)
deltha - Pages num to update.void updateEvictedPages(int deltha)
deltha - Pages num to update.void clearCounters()
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.0 Release Date : October 15 2020