org.apache.flink.state.api.runtime

Class SavepointEnvironment.Builder

java.lang.Object

org.apache.flink.state.api.runtime.SavepointEnvironment.Builder

Enclosing class:

SavepointEnvironment

public static class SavepointEnvironment.Builder
extends Object

SavepointEnvironment builder.

Constructor Summary

Constructors

Constructor and Description
Builder(RuntimeContext ctx, int maxParallelism)

Method Summary

Modifier and Type	Method and Description
SavepointEnvironment	build()
SavepointEnvironment.Builder	setConfiguration(Configuration configuration)
SavepointEnvironment.Builder	setPrioritizedOperatorSubtaskState(PrioritizedOperatorSubtaskState prioritizedOperatorSubtaskState)
SavepointEnvironment.Builder	setSubtaskIndex(int indexOfSubtask)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder(RuntimeContext ctx,
               int maxParallelism)

Method Detail

setSubtaskIndex

public SavepointEnvironment.Builder setSubtaskIndex(int indexOfSubtask)

setConfiguration

public SavepointEnvironment.Builder setConfiguration(Configuration configuration)

setPrioritizedOperatorSubtaskState

public SavepointEnvironment.Builder setPrioritizedOperatorSubtaskState(PrioritizedOperatorSubtaskState prioritizedOperatorSubtaskState)

build

public SavepointEnvironment build()