Package org.apache.flink.runtime.state

Class DefaultOperatorStateBackendBuilder

java.lang.Object

org.apache.flink.runtime.state.DefaultOperatorStateBackendBuilder

All Implemented Interfaces:

StateBackendBuilder<DefaultOperatorStateBackend,BackendBuildingException>

public class DefaultOperatorStateBackendBuilder
extends Object
implements StateBackendBuilder<DefaultOperatorStateBackend,BackendBuildingException>

Builder class for DefaultOperatorStateBackend which handles all necessary initializations and clean ups.

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	asynchronousSnapshots	Flag to de/activate asynchronous snapshots.
protected CloseableRegistry	cancelStreamRegistry
protected ExecutionConfig	executionConfig	The execution configuration.
protected Collection<OperatorStateHandle>	restoreStateHandles	State handles for restore.
protected ClassLoader	userClassloader	The user code classloader.

Constructor Summary

Constructors

Constructor	Description
DefaultOperatorStateBackendBuilder(ClassLoader userClassloader, ExecutionConfig executionConfig, boolean asynchronousSnapshots, Collection<OperatorStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry)

Method Summary

Modifier and Type	Method	Description
DefaultOperatorStateBackend	build()

Methods inherited from class java.lang.Object

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

Field Detail

userClassloader

@VisibleForTesting
protected final ClassLoader userClassloader

The user code classloader.

executionConfig

@VisibleForTesting
protected final ExecutionConfig executionConfig

The execution configuration.

asynchronousSnapshots

@VisibleForTesting
protected final boolean asynchronousSnapshots

Flag to de/activate asynchronous snapshots.

restoreStateHandles

@VisibleForTesting
protected final Collection<OperatorStateHandle> restoreStateHandles

State handles for restore.

cancelStreamRegistry

@VisibleForTesting
protected final CloseableRegistry cancelStreamRegistry

Constructor Detail

DefaultOperatorStateBackendBuilder

public DefaultOperatorStateBackendBuilder(ClassLoader userClassloader,
                                          ExecutionConfig executionConfig,
                                          boolean asynchronousSnapshots,
                                          Collection<OperatorStateHandle> stateHandles,
                                          CloseableRegistry cancelStreamRegistry)

Method Detail

build

public DefaultOperatorStateBackend build()
                                  throws BackendBuildingException

Specified by:

build in interface StateBackendBuilder<DefaultOperatorStateBackend,BackendBuildingException>

Throws:

BackendBuildingException