org.apache.flink.runtime.checkpoint

Class CompletedCheckpoint

java.lang.Object

org.apache.flink.runtime.checkpoint.CompletedCheckpoint

All Implemented Interfaces:

Serializable

public class CompletedCheckpoint
extends Object
implements Serializable

A successful checkpoint describes a checkpoint after all required tasks acknowledged it (with their state) and that is considered completed.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CompletedCheckpoint(JobID job, long checkpointID, long timestamp, long completionTimestamp, ArrayList<StateForTask> states)

Method Summary

Modifier and Type	Method and Description
void	discard(ClassLoader userClassLoader)
long	getCheckpointID()
long	getDuration()
JobID	getJobId()
List<StateForTask>	getStates()
long	getTimestamp()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

CompletedCheckpoint

public CompletedCheckpoint(JobID job,
                           long checkpointID,
                           long timestamp,
                           long completionTimestamp,
                           ArrayList<StateForTask> states)

Method Detail

getJobId

public JobID getJobId()

getCheckpointID

public long getCheckpointID()

getTimestamp

public long getTimestamp()

getDuration

public long getDuration()

getStates

public List<StateForTask> getStates()

discard

public void discard(ClassLoader userClassLoader)

toString

public String toString()

Overrides:

toString in class Object