org.apache.flink.runtime.checkpoint

Class PrioritizedOperatorSubtaskState.Builder

java.lang.Object

org.apache.flink.runtime.checkpoint.PrioritizedOperatorSubtaskState.Builder

Enclosing class:

PrioritizedOperatorSubtaskState

@Internal
public static class PrioritizedOperatorSubtaskState.Builder
extends Object

A builder for PrioritizedOperatorSubtaskState.

Constructor Summary

Constructors

Constructor and Description
Builder(OperatorSubtaskState jobManagerState, List<OperatorSubtaskState> alternativesByPriority)
Builder(OperatorSubtaskState jobManagerState, List<OperatorSubtaskState> alternativesByPriority, Long restoredCheckpointId)

Method Summary

Modifier and Type	Method and Description
PrioritizedOperatorSubtaskState	build()
protected <T extends StateObject> List<StateObjectCollection<T>>	resolvePrioritizedAlternatives(StateObjectCollection<T> jobManagerState, List<StateObjectCollection<T>> alternativesByPriority, java.util.function.BiFunction<T,T,Boolean> approveFun) This helper method resolves the dependencies between the ground truth of the operator state obtained from the job manager and potential alternatives for recovery, e.g.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder(@Nonnull
               OperatorSubtaskState jobManagerState,
               @Nonnull
               List<OperatorSubtaskState> alternativesByPriority)

Builder

public Builder(@Nonnull
               OperatorSubtaskState jobManagerState,
               @Nonnull
               List<OperatorSubtaskState> alternativesByPriority,
               @Nullable
               Long restoredCheckpointId)

Method Detail

build

public PrioritizedOperatorSubtaskState build()

resolvePrioritizedAlternatives

protected <T extends StateObject> List<StateObjectCollection<T>> resolvePrioritizedAlternatives(StateObjectCollection<T> jobManagerState,
                                                                                                List<StateObjectCollection<T>> alternativesByPriority,
                                                                                                java.util.function.BiFunction<T,T,Boolean> approveFun)

This helper method resolves the dependencies between the ground truth of the operator state obtained from the job manager and potential alternatives for recovery, e.g. from a task-local source.