public class FullyFinishedOperatorState extends OperatorState
StateObject.StateObjectLocation, StateObject.StateObjectSizeStatsCollector
Constructor and Description |
---|
FullyFinishedOperatorState(OperatorID operatorID,
int parallelism,
int maxParallelism) |
Modifier and Type | Method and Description |
---|---|
OperatorState |
copyAndDiscardInFlightData() |
boolean |
equals(Object obj) |
int |
hashCode() |
boolean |
isFullyFinished() |
void |
putState(int subtaskIndex,
OperatorSubtaskState subtaskState) |
void |
setCoordinatorState(ByteStreamStateHandle coordinatorState) |
String |
toString() |
collectSizeStats, copyWithNewOperatorID, discardState, getCheckpointedSize, getCoordinatorState, getDiscardables, getMaxParallelism, getNumberCollectedStates, getOperatorID, getParallelism, getState, getStates, getStateSize, getSubtaskStates, hasSubtaskStates, registerSharedStates
public FullyFinishedOperatorState(OperatorID operatorID, int parallelism, int maxParallelism)
public boolean isFullyFinished()
isFullyFinished
in class OperatorState
public void putState(int subtaskIndex, OperatorSubtaskState subtaskState)
putState
in class OperatorState
public void setCoordinatorState(@Nullable ByteStreamStateHandle coordinatorState)
setCoordinatorState
in class OperatorState
public OperatorState copyAndDiscardInFlightData()
copyAndDiscardInFlightData
in class OperatorState
public int hashCode()
hashCode
in class OperatorState
public boolean equals(Object obj)
equals
in class OperatorState
public String toString()
toString
in class OperatorState
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.