org.apache.flink.runtime.checkpoint.metadata

Class CheckpointMetadata

java.lang.Object

org.apache.flink.runtime.checkpoint.metadata.CheckpointMetadata

All Implemented Interfaces:

Disposable

public class CheckpointMetadata
extends Object
implements Disposable

The metadata of a snapshot (checkpoint or savepoint).

Constructor Summary

Constructors

Constructor and Description
CheckpointMetadata(long checkpointId, Collection<OperatorState> operatorStates, Collection<MasterState> masterStates)
CheckpointMetadata(long checkpointId, Collection<OperatorState> operatorStates, Collection<MasterState> masterStates, CheckpointProperties properties)

Method Summary

Modifier and Type	Method and Description
void	dispose() Disposes the object and releases all resources.
long	getCheckpointId()
CheckpointProperties	getCheckpointProperties()
Collection<MasterState>	getMasterStates()
Collection<OperatorState>	getOperatorStates()
String	toString()
CheckpointMetadata	withProperties(CheckpointProperties properties)

Methods inherited from class java.lang.Object

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

Constructor Detail

CheckpointMetadata

public CheckpointMetadata(long checkpointId,
                          Collection<OperatorState> operatorStates,
                          Collection<MasterState> masterStates)

CheckpointMetadata

public CheckpointMetadata(long checkpointId,
                          Collection<OperatorState> operatorStates,
                          Collection<MasterState> masterStates,
                          @Nullable
                          CheckpointProperties properties)

Method Detail

getCheckpointId

public long getCheckpointId()

getOperatorStates

public Collection<OperatorState> getOperatorStates()

getMasterStates

public Collection<MasterState> getMasterStates()

dispose

public void dispose()
             throws Exception

Description copied from interface: Disposable

Disposes the object and releases all resources. After calling this method, calling any methods on the object may result in undefined behavior.

Specified by:

dispose in interface Disposable

Throws:

Exception - if something goes wrong during disposal.

toString

public String toString()

Overrides:

toString in class Object

getCheckpointProperties

@Nullable
public CheckpointProperties getCheckpointProperties()

withProperties

public CheckpointMetadata withProperties(CheckpointProperties properties)