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

Class SavepointMetadata

java.lang.Object

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

@Internal
@Deprecated
public class SavepointMetadata
extends Object

Deprecated.

Savepoint metadata that can be modified.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	addOperator(String uid, BootstrapTransformation<?> transformation)	Deprecated.
long	getCheckpointId()	Deprecated.
List<org.apache.flink.runtime.checkpoint.OperatorState>	getExistingOperators()	Deprecated.
Collection<org.apache.flink.runtime.checkpoint.MasterState>	getMasterStates()	Deprecated.
int	getMaxParallelism()	Deprecated.
List<BootstrapTransformationWithID<?>>	getNewOperators()	Deprecated.
org.apache.flink.runtime.checkpoint.OperatorState	getOperatorState(String uid)	Deprecated.
void	removeOperator(String uid)	Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

SavepointMetadata

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

Deprecated.

Method Detail

getCheckpointId

public long getCheckpointId()

Deprecated.

getMaxParallelism

public int getMaxParallelism()

Deprecated.

getMasterStates

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

Deprecated.

getOperatorState

public org.apache.flink.runtime.checkpoint.OperatorState getOperatorState(String uid)
                                                                   throws IOException

Deprecated.

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(String uid)

Deprecated.

addOperator

public void addOperator(String uid,
                        BootstrapTransformation<?> transformation)

Deprecated.

getExistingOperators

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

Deprecated.

Returns:

List of OperatorState that already exists within the savepoint.

getNewOperators

public List<BootstrapTransformationWithID<?>> getNewOperators()

Deprecated.

Returns:

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