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() |
void |
onStateChanged(CheckpointState state,
Runnable clo)
Invokes a callback closure then a checkpoint reaches specific state.
|
@Nullable String |
reason() |
AtomicInteger |
syncedPagesCounter() |
void |
transitTo(@NotNull CheckpointState newState)
Changing checkpoint state if order of state is correct.
|
void |
updateEvictedPages(int delta)
Update evicted pages in checkpoint;
|
void |
updateSyncedPages(int delta)
Update synced pages in checkpoint;
|
void |
updateWrittenPages(int delta)
Update written pages in checkpoint;
|
AtomicInteger |
writtenPagesCounter() |
@Nullable @Nullable String reason()
boolean inProgress()
true if the current checkpoint is in CheckpointState which shows that checkpoint has
already started but not finished yet.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 delta)
delta - Pages num to update.void updateWrittenPages(int delta)
delta - Pages num to update.void updateEvictedPages(int delta)
delta - Pages num to update.void clearCounters()
void onStateChanged(CheckpointState state, Runnable clo)
state - State.clo - Closure to call.
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.1 Release Date : December 20 2021