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

Class SavepointMetadata

java.lang.Object

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

Deprecated.

@Internal
 @Deprecated
public class SavepointMetadata
extends Object

Savepoint metadata that can be modified.

Constructor Summary

Constructors

Constructor and Description
SavepointMetadata(int maxParallelism, Collection<MasterState> masterStates, Collection<OperatorState> initialStates) Deprecated.

Method Summary

Modifier and Type	Method and Description
void	addOperator(String uid, BootstrapTransformation<?> transformation) Deprecated.
List<OperatorState>	getExistingOperators() Deprecated.
Collection<MasterState>	getMasterStates() Deprecated.
int	getMaxParallelism() Deprecated.
List<BootstrapTransformationWithID<?>>	getNewOperators() Deprecated.
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(int maxParallelism,
                         Collection<MasterState> masterStates,
                         Collection<OperatorState> initialStates)

Deprecated.

Method Detail

getMaxParallelism

public int getMaxParallelism()

Deprecated.

getMasterStates

public Collection<MasterState> getMasterStates()

Deprecated.

getOperatorState

public 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<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.