org.apache.flink.runtime.checkpoint

Class CheckpointProperties

java.lang.Object

org.apache.flink.runtime.checkpoint.CheckpointProperties

All Implemented Interfaces:

Serializable

public class CheckpointProperties
extends Object
implements Serializable

The configuration of a checkpoint. This describes whether

• The checkpoint is s regular checkpoint or a savepoint.
• When the checkpoint should be garbage collected.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
static CheckpointProperties	forCheckpoint(CheckpointRetentionPolicy policy) Creates the checkpoint properties for a checkpoint.
static CheckpointProperties	forSavepoint() Creates the checkpoint properties for a (manually triggered) savepoint.
CheckpointType	getCheckpointType() Gets the type of the checkpoint (checkpoint / savepoint).
int	hashCode()
boolean	isSavepoint() Returns whether the checkpoint properties describe a standard savepoint.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

getCheckpointType

public CheckpointType getCheckpointType()

Gets the type of the checkpoint (checkpoint / savepoint).

isSavepoint

public boolean isSavepoint()

Returns whether the checkpoint properties describe a standard savepoint.

Returns:

true if the properties describe a savepoint, false otherwise.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

forSavepoint

public static CheckpointProperties forSavepoint()

Creates the checkpoint properties for a (manually triggered) savepoint.

Savepoints are not queued due to time trigger limits. They have to be garbage collected manually.

Returns:

Checkpoint properties for a (manually triggered) savepoint.

forCheckpoint

public static CheckpointProperties forCheckpoint(CheckpointRetentionPolicy policy)

Creates the checkpoint properties for a checkpoint.

Checkpoints may be queued in case too many other checkpoints are currently happening. They are garbage collected automatically, except when the owning job terminates in state JobStatus.FAILED. The user is required to configure the clean up behaviour on job cancellation.

Returns:

Checkpoint properties for an external checkpoint.