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()
boolean	needToSnapshot(String cacheOrGrpName)
boolean	nextSnapshot()
PartitionAllocationMap	partitionStatMap()
CheckpointProgress	progress()

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.

nextSnapshot

public boolean nextSnapshot()

Specified by:

nextSnapshot in interface CheckpointListener.Context

Returns:

True if a snapshot have to be created after.

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

needToSnapshot

public boolean needToSnapshot(String cacheOrGrpName)

Specified by:

needToSnapshot in interface CheckpointListener.Context

Parameters:

cacheOrGrpName - Cache or group name.

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.