org.apache.flink.runtime.checkpoint

Class CheckpointOptions

java.lang.Object

org.apache.flink.runtime.checkpoint.CheckpointOptions

All Implemented Interfaces:

Serializable

public class CheckpointOptions
extends Object
implements Serializable

Options for performing the checkpoint. Note that different barriers may have different options.

The CheckpointProperties are related and cover properties that are only relevant at the CheckpointCoordinator. These options are relevant at the AbstractInvokable instances running on task managers.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CheckpointOptions.AlignmentType How a checkpoint should be aligned.

Field Summary

Fields

Modifier and Type	Field and Description
static long	NO_ALIGNMENT_TIME_OUT

Constructor Summary

Constructors

Constructor and Description
CheckpointOptions(CheckpointType checkpointType, CheckpointStorageLocationReference targetLocation)
CheckpointOptions(CheckpointType checkpointType, CheckpointStorageLocationReference targetLocation, CheckpointOptions.AlignmentType alignmentType, long alignmentTimeout)

Method Summary

Modifier and Type	Method and Description
static CheckpointOptions	alignedNoTimeout(CheckpointType type, CheckpointStorageLocationReference location)
static CheckpointOptions	alignedWithTimeout(CheckpointStorageLocationReference location, long alignmentTimeout)
boolean	equals(Object obj)
static CheckpointOptions	forCheckpointWithDefaultLocation()
static CheckpointOptions	forConfig(CheckpointType checkpointType, CheckpointStorageLocationReference locationReference, boolean isExactlyOnceMode, boolean isUnalignedEnabled, long alignmentTimeout)
CheckpointOptions.AlignmentType	getAlignment()
long	getAlignmentTimeout()
CheckpointType	getCheckpointType() Returns the type of checkpoint to perform.
CheckpointStorageLocationReference	getTargetLocation() Returns the target location for the checkpoint.
int	hashCode()
boolean	isExactlyOnceMode()
boolean	isTimeoutable()
boolean	isUnalignedCheckpoint()
boolean	needsAlignment()
static CheckpointOptions	notExactlyOnce(CheckpointType type, CheckpointStorageLocationReference location)
String	toString()
CheckpointOptions	toUnaligned()
static CheckpointOptions	unaligned(CheckpointStorageLocationReference location)
CheckpointOptions	withUnalignedSupported()
CheckpointOptions	withUnalignedUnsupported()

Methods inherited from class java.lang.Object

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

Field Detail

NO_ALIGNMENT_TIME_OUT

public static final long NO_ALIGNMENT_TIME_OUT

See Also:

Constant Field Values

Constructor Detail

CheckpointOptions

@VisibleForTesting
public CheckpointOptions(CheckpointType checkpointType,
                                            CheckpointStorageLocationReference targetLocation)

CheckpointOptions

public CheckpointOptions(CheckpointType checkpointType,
                         CheckpointStorageLocationReference targetLocation,
                         CheckpointOptions.AlignmentType alignmentType,
                         long alignmentTimeout)

Method Detail

notExactlyOnce

public static CheckpointOptions notExactlyOnce(CheckpointType type,
                                               CheckpointStorageLocationReference location)

alignedNoTimeout

public static CheckpointOptions alignedNoTimeout(CheckpointType type,
                                                 CheckpointStorageLocationReference location)

unaligned

public static CheckpointOptions unaligned(CheckpointStorageLocationReference location)

alignedWithTimeout

public static CheckpointOptions alignedWithTimeout(CheckpointStorageLocationReference location,
                                                   long alignmentTimeout)

forConfig

public static CheckpointOptions forConfig(CheckpointType checkpointType,
                                          CheckpointStorageLocationReference locationReference,
                                          boolean isExactlyOnceMode,
                                          boolean isUnalignedEnabled,
                                          long alignmentTimeout)

needsAlignment

public boolean needsAlignment()

getAlignmentTimeout

public long getAlignmentTimeout()

getAlignment

public CheckpointOptions.AlignmentType getAlignment()

isTimeoutable

public boolean isTimeoutable()

getCheckpointType

public CheckpointType getCheckpointType()

Returns the type of checkpoint to perform.

getTargetLocation

public CheckpointStorageLocationReference getTargetLocation()

Returns the target location for the checkpoint.

isExactlyOnceMode

public boolean isExactlyOnceMode()

isUnalignedCheckpoint

public boolean isUnalignedCheckpoint()

withUnalignedSupported

public CheckpointOptions withUnalignedSupported()

withUnalignedUnsupported

public CheckpointOptions withUnalignedUnsupported()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

forCheckpointWithDefaultLocation

@VisibleForTesting
public static CheckpointOptions forCheckpointWithDefaultLocation()

toUnaligned

public CheckpointOptions toUnaligned()