Package org.apache.flink.state.forst

Class ForStKeyedStateBackendBuilder<K>

java.lang.Object

org.apache.flink.state.forst.ForStKeyedStateBackendBuilder<K>

Type Parameters:

K - The data type that the key serializer serializes.

All Implemented Interfaces:

StateBackendBuilder<ForStKeyedStateBackend<K>,BackendBuildingException>

public class ForStKeyedStateBackendBuilder<K>
extends Object
implements StateBackendBuilder<ForStKeyedStateBackend<K>,BackendBuildingException>

Builder class for ForStKeyedStateBackend which handles all necessary initializations and cleanups.

Field Summary

Fields

Modifier and Type	Field	Description
protected CloseableRegistry	cancelStreamRegistry
protected org.slf4j.Logger	logger
protected ClassLoader	userCodeClassLoader

Constructor Summary

Constructors

Constructor

Description

ForStKeyedStateBackendBuilder(String operatorIdentifier, ClassLoader userCodeClassLoader, ForStResourceContainer optionsContainer, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, ForStPriorityQueueConfig priorityQueueConfig, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, StateBackend.CustomInitializationMetrics customInitializationMetrics, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry)

Method Summary

Modifier and Type	Method	Description
ForStKeyedStateBackend<K>	build()

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.slf4j.Logger logger

userCodeClassLoader

protected final ClassLoader userCodeClassLoader

cancelStreamRegistry

protected final CloseableRegistry cancelStreamRegistry

Constructor Detail

ForStKeyedStateBackendBuilder

public ForStKeyedStateBackendBuilder(String operatorIdentifier,
                                     ClassLoader userCodeClassLoader,
                                     ForStResourceContainer optionsContainer,
                                     Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
                                     TypeSerializer<K> keySerializer,
                                     int numberOfKeyGroups,
                                     KeyGroupRange keyGroupRange,
                                     ForStPriorityQueueConfig priorityQueueConfig,
                                     TtlTimeProvider ttlTimeProvider,
                                     MetricGroup metricGroup,
                                     StateBackend.CustomInitializationMetrics customInitializationMetrics,
                                     @Nonnull
                                     Collection<KeyedStateHandle> stateHandles,
                                     CloseableRegistry cancelStreamRegistry)

Method Detail

build

public ForStKeyedStateBackend<K> build()
                                throws BackendBuildingException

Specified by:

build in interface StateBackendBuilder<ForStKeyedStateBackend<K>,BackendBuildingException>

Throws:

BackendBuildingException