Interface PrioritizedOperatorSubtaskStateInputSplit

  • All Superinterfaces:
    org.apache.flink.core.io.InputSplit, Serializable
    All Known Implementing Classes:
    KeyGroupRangeInputSplit, OperatorStateInputSplit

    @Internal
    public interface PrioritizedOperatorSubtaskStateInputSplit
    extends org.apache.flink.core.io.InputSplit
    An input split that returns PrioritizedOperatorSubtaskState.
    • Method Detail

      • getPrioritizedOperatorSubtaskState

        org.apache.flink.runtime.checkpoint.PrioritizedOperatorSubtaskState getPrioritizedOperatorSubtaskState()