Package org.apache.ignite.internal.persistence.checkpoint

Class CheckpointerImpl

java.lang.Object

org.apache.ignite.internal.persistence.checkpoint.CheckpointerImpl

All Implemented Interfaces:

Checkpointer

public final class CheckpointerImpl
extends Object
implements Checkpointer

The default implementation of Checkpointer interface.

Constructor Summary

Constructors

Constructor	Description
CheckpointerImpl(long checkpointPeriod, long walSizeThreshold, WalManager walManager, StoreManager storeManager, DataRegionManager dataRegionManager)	Constructs a new instance.

Method Summary

Modifier and Type	Method	Description
CheckpointRequirementLevel	getCheckpointRequirementLevel()	Gets checkpoint requirement level.
long	getLastCheckpointTime()	Gets last checkpoint time.
void	runCheckpoint()	Runs checkpoint.

Methods inherited from class java.lang.Object

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

Constructor Details

CheckpointerImpl

public CheckpointerImpl(long checkpointPeriod,
 long walSizeThreshold,
 WalManager walManager,
 StoreManager storeManager,
 DataRegionManager dataRegionManager)

Constructs a new instance.

Parameters:

checkpointPeriod - The checkpoint period in milliseconds.

walSizeThreshold - The WAL size threshold in bytes.

walManager - The WAL manager. May not be null.

storeManager - The store manager. May not be null.

dataRegionManager - The data region manager. May not be null.

Method Details

getCheckpointRequirementLevel

public CheckpointRequirementLevel getCheckpointRequirementLevel()
                                                         throws IgniteCheckedException

Description copied from interface: Checkpointer

Gets checkpoint requirement level.

Specified by:

getCheckpointRequirementLevel in interface Checkpointer

Returns:

the checkpoint requirement level. Never null.

Throws:

IgniteCheckedException - in case of a failure.

getLastCheckpointTime

public long getLastCheckpointTime()

Description copied from interface: Checkpointer

Gets last checkpoint time.

Specified by:

getLastCheckpointTime in interface Checkpointer

Returns:

the last checkpoint time (the difference, measured in milliseconds, between the last checkpoint time and midnight, January 1, 1970 UTC.)

runCheckpoint

public void runCheckpoint()
                   throws IgniteCheckedException

Description copied from interface: Checkpointer

Runs checkpoint.

Specified by:

runCheckpoint in interface Checkpointer

Throws:

IgniteCheckedException - in case of a failure.