org.apache.flink.runtime.checkpoint

Class OperatorSubtaskState.Builder

java.lang.Object

org.apache.flink.runtime.checkpoint.OperatorSubtaskState.Builder

Enclosing class:

OperatorSubtaskState

public static class OperatorSubtaskState.Builder
extends Object

The builder for a new OperatorSubtaskState which can be obtained by OperatorSubtaskState.builder().

Method Summary

Modifier and Type	Method and Description
OperatorSubtaskState	build()
OperatorSubtaskState.Builder	setInputChannelState(StateObjectCollection<InputChannelStateHandle> inputChannelState)
OperatorSubtaskState.Builder	setInputRescalingDescriptor(InflightDataRescalingDescriptor inputRescalingDescriptor)
OperatorSubtaskState.Builder	setManagedKeyedState(KeyedStateHandle managedKeyedState)
OperatorSubtaskState.Builder	setManagedKeyedState(StateObjectCollection<KeyedStateHandle> managedKeyedState)
OperatorSubtaskState.Builder	setManagedOperatorState(OperatorStateHandle managedOperatorState)
OperatorSubtaskState.Builder	setManagedOperatorState(StateObjectCollection<OperatorStateHandle> managedOperatorState)
OperatorSubtaskState.Builder	setOutputRescalingDescriptor(InflightDataRescalingDescriptor outputRescalingDescriptor)
OperatorSubtaskState.Builder	setRawKeyedState(KeyedStateHandle rawKeyedState)
OperatorSubtaskState.Builder	setRawKeyedState(StateObjectCollection<KeyedStateHandle> rawKeyedState)
OperatorSubtaskState.Builder	setRawOperatorState(OperatorStateHandle rawOperatorState)
OperatorSubtaskState.Builder	setRawOperatorState(StateObjectCollection<OperatorStateHandle> rawOperatorState)
OperatorSubtaskState.Builder	setResultSubpartitionState(StateObjectCollection<ResultSubpartitionStateHandle> resultSubpartitionState)

Methods inherited from class java.lang.Object

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

Method Detail

setManagedOperatorState

public OperatorSubtaskState.Builder setManagedOperatorState(StateObjectCollection<OperatorStateHandle> managedOperatorState)

setManagedOperatorState

public OperatorSubtaskState.Builder setManagedOperatorState(OperatorStateHandle managedOperatorState)

setRawOperatorState

public OperatorSubtaskState.Builder setRawOperatorState(StateObjectCollection<OperatorStateHandle> rawOperatorState)

setRawOperatorState

public OperatorSubtaskState.Builder setRawOperatorState(OperatorStateHandle rawOperatorState)

setManagedKeyedState

public OperatorSubtaskState.Builder setManagedKeyedState(StateObjectCollection<KeyedStateHandle> managedKeyedState)

setManagedKeyedState

public OperatorSubtaskState.Builder setManagedKeyedState(KeyedStateHandle managedKeyedState)

setRawKeyedState

public OperatorSubtaskState.Builder setRawKeyedState(StateObjectCollection<KeyedStateHandle> rawKeyedState)

setRawKeyedState

public OperatorSubtaskState.Builder setRawKeyedState(KeyedStateHandle rawKeyedState)

setInputChannelState

public OperatorSubtaskState.Builder setInputChannelState(StateObjectCollection<InputChannelStateHandle> inputChannelState)

setResultSubpartitionState

public OperatorSubtaskState.Builder setResultSubpartitionState(StateObjectCollection<ResultSubpartitionStateHandle> resultSubpartitionState)

setInputRescalingDescriptor

public OperatorSubtaskState.Builder setInputRescalingDescriptor(InflightDataRescalingDescriptor inputRescalingDescriptor)

setOutputRescalingDescriptor

public OperatorSubtaskState.Builder setOutputRescalingDescriptor(InflightDataRescalingDescriptor outputRescalingDescriptor)

build

public OperatorSubtaskState build()