Class OperatorState
- java.lang.Object
-
- org.apache.flink.runtime.checkpoint.OperatorState
-
- All Implemented Interfaces:
Serializable
,CompositeStateHandle
,StateObject
- Direct Known Subclasses:
FullyFinishedOperatorState
public class OperatorState extends Object implements CompositeStateHandle
Simple container class which contains the raw/managed operator state and key-group state handles from all subtasks of an operator and therefore represents the complete state of a logical operator.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.flink.runtime.state.StateObject
StateObject.StateObjectLocation, StateObject.StateObjectSizeStatsCollector
-
-
Constructor Summary
Constructors Constructor Description OperatorState(String operatorName, String operatorUid, OperatorID operatorID, int parallelism, int maxParallelism)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
collectSizeStats(StateObject.StateObjectSizeStatsCollector collector)
Collects statistics about state size and location from the state object.OperatorState
copyAndDiscardInFlightData()
OperatorState
copyWithNewIDs(String newOperatorUid, OperatorID newOperatorId)
void
discardState()
Discards the state referred to and solemnly owned by this handle, to free up resources in the persistent storage.boolean
equals(Object obj)
long
getCheckpointedSize()
Returns the persisted data size during checkpoint execution in bytes.ByteStreamStateHandle
getCoordinatorState()
List<StateObject>
getDiscardables()
int
getMaxParallelism()
int
getNumberCollectedStates()
OperatorID
getOperatorID()
Optional<String>
getOperatorName()
Optional<String>
getOperatorUid()
int
getParallelism()
OperatorSubtaskState
getState(int subtaskIndex)
Collection<OperatorSubtaskState>
getStates()
long
getStateSize()
Returns the size of the state in bytes.Map<Integer,OperatorSubtaskState>
getSubtaskStates()
int
hashCode()
boolean
hasSubtaskStates()
boolean
isFullyFinished()
void
putState(int subtaskIndex, OperatorSubtaskState subtaskState)
void
registerSharedStates(SharedStateRegistry sharedStateRegistry, long checkpointID)
Register both newly created and already referenced shared states in the givenSharedStateRegistry
.void
setCoordinatorState(ByteStreamStateHandle coordinatorState)
void
setOperatorName(String operatorName)
void
setOperatorUid(String operatorUid)
String
toString()
-
-
-
Constructor Detail
-
OperatorState
public OperatorState(@Nullable String operatorName, @Nullable String operatorUid, OperatorID operatorID, int parallelism, int maxParallelism)
-
-
Method Detail
-
setOperatorName
public void setOperatorName(String operatorName)
-
setOperatorUid
public void setOperatorUid(String operatorUid)
-
getOperatorID
public OperatorID getOperatorID()
-
isFullyFinished
public boolean isFullyFinished()
-
putState
public void putState(int subtaskIndex, OperatorSubtaskState subtaskState)
-
getState
public OperatorSubtaskState getState(int subtaskIndex)
-
setCoordinatorState
public void setCoordinatorState(@Nullable ByteStreamStateHandle coordinatorState)
-
getCoordinatorState
@Nullable public ByteStreamStateHandle getCoordinatorState()
-
getSubtaskStates
public Map<Integer,OperatorSubtaskState> getSubtaskStates()
-
getStates
public Collection<OperatorSubtaskState> getStates()
-
getNumberCollectedStates
public int getNumberCollectedStates()
-
getParallelism
public int getParallelism()
-
getMaxParallelism
public int getMaxParallelism()
-
copyWithNewIDs
public OperatorState copyWithNewIDs(@Nullable String newOperatorUid, OperatorID newOperatorId)
-
copyAndDiscardInFlightData
public OperatorState copyAndDiscardInFlightData()
-
getDiscardables
public List<StateObject> getDiscardables()
-
discardState
public void discardState() throws Exception
Description copied from interface:StateObject
Discards the state referred to and solemnly owned by this handle, to free up resources in the persistent storage. This method is called when the state represented by this object will not be used anymore.- Specified by:
discardState
in interfaceStateObject
- Throws:
Exception
-
registerSharedStates
public void registerSharedStates(SharedStateRegistry sharedStateRegistry, long checkpointID)
Description copied from interface:CompositeStateHandle
Register both newly created and already referenced shared states in the givenSharedStateRegistry
. This method is called when the checkpoint successfully completes or is recovered from failures.After this is completed, newly created shared state is considered as published is no longer owned by this handle. This means that it should no longer be deleted as part of calls to
StateObject.discardState()
. Instead,StateObject.discardState()
will trigger an unregistration from the registry.- Specified by:
registerSharedStates
in interfaceCompositeStateHandle
- Parameters:
sharedStateRegistry
- The registry where shared states are registered.
-
hasSubtaskStates
public boolean hasSubtaskStates()
-
getStateSize
public long getStateSize()
Description copied from interface:StateObject
Returns the size of the state in bytes. If the size is not known, this method should return0
.The values produced by this method are only used for informational purposes and for metrics/monitoring. If this method returns wrong values, the checkpoints and recovery will still behave correctly. However, efficiency may be impacted (wrong space pre-allocation) and functionality that depends on metrics (like monitoring) will be impacted.
Note for implementors: This method should not perform any I/O operations while obtaining the state size (hence it does not declare throwing an
IOException
). Instead, the state size should be stored in the state object, or should be computable from the state stored in this object. The reason is that this method is called frequently by several parts of the checkpointing and issuing I/O requests from this method accumulates a heavy I/O load on the storage system at higher scale.- Specified by:
getStateSize
in interfaceStateObject
- Returns:
- Size of the state in bytes.
-
collectSizeStats
public void collectSizeStats(StateObject.StateObjectSizeStatsCollector collector)
Description copied from interface:StateObject
Collects statistics about state size and location from the state object.- Specified by:
collectSizeStats
in interfaceStateObject
- Parameters:
collector
- the statistics collector.
-
getCheckpointedSize
public long getCheckpointedSize()
Description copied from interface:CompositeStateHandle
Returns the persisted data size during checkpoint execution in bytes. If incremental checkpoint is enabled, this value represents the incremental persisted data size, and usually smaller thanStateObject.getStateSize()
. If the size is unknown, this method would return same result asStateObject.getStateSize()
.- Specified by:
getCheckpointedSize
in interfaceCompositeStateHandle
- Returns:
- The persisted data size during checkpoint execution in bytes.
-
-