Package org.apache.flink.runtime.checkpoint

Class FinishedOperatorSubtaskState

java.lang.Object

org.apache.flink.runtime.checkpoint.OperatorSubtaskState

org.apache.flink.runtime.checkpoint.FinishedOperatorSubtaskState

All Implemented Interfaces:

Serializable, CompositeStateHandle, StateObject

public class FinishedOperatorSubtaskState
extends OperatorSubtaskState

A specialized OperatorSubtaskState representing the subtask is finished. It is also read-only and could not have actual states.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.runtime.checkpoint.OperatorSubtaskState

OperatorSubtaskState.Builder

Nested classes/interfaces inherited from interface org.apache.flink.runtime.state.StateObject

StateObject.StateObjectLocation, StateObject.StateObjectSizeStatsCollector

Field Summary

Fields

Modifier and Type	Field	Description
static FinishedOperatorSubtaskState	INSTANCE

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	hashCode()
boolean	isFinished()
String	toString()

Methods inherited from class org.apache.flink.runtime.checkpoint.OperatorSubtaskState

builder, discardState, getCheckpointedSize, getDiscardables, getInputChannelState, getInputRescalingDescriptor, getManagedKeyedState, getManagedOperatorState, getOutputRescalingDescriptor, getRawKeyedState, getRawOperatorState, getResultSubpartitionState, getStateSize, hasState, registerSharedStates, toBuilder

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.flink.runtime.state.StateObject

collectSizeStats

Field Detail

INSTANCE

public static final FinishedOperatorSubtaskState INSTANCE

Method Detail

isFinished

public boolean isFinished()

Overrides:

isFinished in class OperatorSubtaskState

hashCode

public int hashCode()

Overrides:

hashCode in class OperatorSubtaskState

equals

public boolean equals(Object o)

Overrides:

equals in class OperatorSubtaskState

toString

public String toString()

Overrides:

toString in class OperatorSubtaskState