org.apache.flink.runtime.checkpoint

Class SavepointType

java.lang.Object

org.apache.flink.runtime.checkpoint.SavepointType

All Implemented Interfaces:

Serializable, SnapshotType

public class SavepointType
extends Object
implements SnapshotType

The type of checkpoint to perform.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SavepointType.PostCheckpointAction What's the intended action after the checkpoint (relevant for stopping with savepoint).

Nested classes/interfaces inherited from interface org.apache.flink.runtime.checkpoint.SnapshotType

SnapshotType.SharingFilesStrategy

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
SavepointFormatType	getFormatType()
String	getName()
SavepointType.PostCheckpointAction	getPostCheckpointAction()
SnapshotType.SharingFilesStrategy	getSharingFilesStrategy()
int	hashCode()
boolean	isSavepoint()
boolean	isSynchronous()
static SavepointType	savepoint(SavepointFormatType formatType)
boolean	shouldAdvanceToEndOfTime()
boolean	shouldDrain()
boolean	shouldIgnoreEndOfInput()
static SavepointType	suspend(SavepointFormatType formatType)
static SavepointType	terminate(SavepointFormatType formatType)
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

savepoint

public static SavepointType savepoint(SavepointFormatType formatType)

terminate

public static SavepointType terminate(SavepointFormatType formatType)

suspend

public static SavepointType suspend(SavepointFormatType formatType)

isSavepoint

public boolean isSavepoint()

Specified by:

isSavepoint in interface SnapshotType

isSynchronous

public boolean isSynchronous()

getPostCheckpointAction

public SavepointType.PostCheckpointAction getPostCheckpointAction()

shouldAdvanceToEndOfTime

public boolean shouldAdvanceToEndOfTime()

shouldDrain

public boolean shouldDrain()

shouldIgnoreEndOfInput

public boolean shouldIgnoreEndOfInput()

getName

public String getName()

Specified by:

getName in interface SnapshotType

getFormatType

public SavepointFormatType getFormatType()

getSharingFilesStrategy

public SnapshotType.SharingFilesStrategy getSharingFilesStrategy()

Specified by:

getSharingFilesStrategy in interface SnapshotType

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