Package org.apache.flink.state.api.runtime.metadata

Class SavepointMetadataV2

java.lang.Object

org.apache.flink.state.api.runtime.metadata.SavepointMetadataV2

@Internal
public class SavepointMetadataV2
extends Object

Savepoint metadata that can be modified.

Constructor Summary

Constructors

Constructor	Description
SavepointMetadataV2(long checkpointId, int maxParallelism, Collection<org.apache.flink.runtime.checkpoint.MasterState> masterStates, Collection<org.apache.flink.runtime.checkpoint.OperatorState> initialStates)

Method Summary

Modifier and Type	Method	Description
void	addOperator(OperatorIdentifier identifier, StateBootstrapTransformation<?> transformation)
long	getCheckpointId()
List<org.apache.flink.runtime.checkpoint.OperatorState>	getExistingOperators()
Collection<org.apache.flink.runtime.checkpoint.MasterState>	getMasterStates()
int	getMaxParallelism()
List<StateBootstrapTransformationWithID<?>>	getNewOperators()
org.apache.flink.runtime.checkpoint.OperatorState	getOperatorState(OperatorIdentifier identifier)
void	removeOperator(OperatorIdentifier identifier)

Methods inherited from class java.lang.Object

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

Constructor Detail

SavepointMetadataV2

public SavepointMetadataV2(long checkpointId,
                           int maxParallelism,
                           Collection<org.apache.flink.runtime.checkpoint.MasterState> masterStates,
                           Collection<org.apache.flink.runtime.checkpoint.OperatorState> initialStates)

Method Detail

getCheckpointId

public long getCheckpointId()

getMaxParallelism

public int getMaxParallelism()

getMasterStates

public Collection<org.apache.flink.runtime.checkpoint.MasterState> getMasterStates()

getOperatorState

public org.apache.flink.runtime.checkpoint.OperatorState getOperatorState(OperatorIdentifier identifier)
                                                                   throws IOException

Returns:

Operator state for the given UID.

Throws:

IOException - If the savepoint does not contain operator state with the given uid.

removeOperator

public void removeOperator(OperatorIdentifier identifier)

addOperator

public void addOperator(OperatorIdentifier identifier,
                        StateBootstrapTransformation<?> transformation)

getExistingOperators

public List<org.apache.flink.runtime.checkpoint.OperatorState> getExistingOperators()

Returns:

List of OperatorState that already exists within the savepoint.

getNewOperators

public List<StateBootstrapTransformationWithID<?>> getNewOperators()

Returns:

List of new operator states for the savepoint, represented by their target OperatorID and StateBootstrapTransformation.