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

Class CheckpointContextImpl

java.lang.Object

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

All Implemented Interfaces:

CheckpointListener.Context

public class CheckpointContextImpl
extends Object
implements CheckpointListener.Context

Context with information about current checkpoint.

Method Summary

Modifier and Type	Method and Description
void	awaitPendingTasksFinished() Await all async tasks from executor was finished.
Executor	executor()
IgniteInternalFuture<?>	finishedStateFut()
PartitionAllocationMap	partitionStatMap()
CheckpointProgress	progress()
boolean	walFlush() Whether to flush WAL after a Checkpoint begin.
void	walFlush(boolean flush)

Methods inherited from class java.lang.Object

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

Method Detail

progress

public CheckpointProgress progress()

Specified by:

progress in interface CheckpointListener.Context

Returns:

Checkpoint progress callback.

walFlush

public void walFlush(boolean flush)

Specified by:

walFlush in interface CheckpointListener.Context

Parameters:

flush - If True then will flush WAL after a Checkpoint begin.

walFlush

public boolean walFlush()

Whether to flush WAL after a Checkpoint begin.

Specified by:

walFlush in interface CheckpointListener.Context

finishedStateFut

public IgniteInternalFuture<?> finishedStateFut()

Specified by:

finishedStateFut in interface CheckpointListener.Context

Returns:

Checkpoint future which will be completed when checkpoint ends.

partitionStatMap

public PartitionAllocationMap partitionStatMap()

Specified by:

partitionStatMap in interface CheckpointListener.Context

Returns:

Partition allocation statistic map

executor

public Executor executor()

Specified by:

executor in interface CheckpointListener.Context

Returns:

Context executor.

awaitPendingTasksFinished

public void awaitPendingTasksFinished()
                               throws IgniteCheckedException

Await all async tasks from executor was finished.

Throws:

IgniteCheckedException - if fail.