Constructor and Description |
---|
SavepointMetadata(int maxParallelism,
Collection<MasterState> masterStates,
Collection<OperatorState> initialStates) |
Modifier and Type | Method and Description |
---|---|
void |
addOperator(String uid,
BootstrapTransformation<?> transformation) |
List<OperatorState> |
getExistingOperators() |
Collection<MasterState> |
getMasterStates() |
int |
getMaxParallelism() |
List<BootstrapTransformationWithID<?>> |
getNewOperators() |
OperatorState |
getOperatorState(String uid) |
void |
removeOperator(String uid) |
public SavepointMetadata(int maxParallelism, Collection<MasterState> masterStates, Collection<OperatorState> initialStates)
public int getMaxParallelism()
public Collection<MasterState> getMasterStates()
public OperatorState getOperatorState(String uid) throws IOException
IOException
- If the savepoint does not contain operator state with the given uid.public void removeOperator(String uid)
public void addOperator(String uid, BootstrapTransformation<?> transformation)
public List<OperatorState> getExistingOperators()
OperatorState
that already exists within the savepoint.public List<BootstrapTransformationWithID<?>> getNewOperators()
OperatorID
and BootstrapTransformation
.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.