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(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)
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(int maxParallelism,
                           Collection<org.apache.flink.runtime.checkpoint.MasterState> masterStates,
                           Collection<org.apache.flink.runtime.checkpoint.OperatorState> initialStates)

Method Detail

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.