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:

org.apache.flink.runtime.state.StateBackendBuilder<ForStKeyedStateBackend<K>,org.apache.flink.runtime.state.BackendBuildingException>

public class ForStKeyedStateBackendBuilder<K>
extends Object
implements org.apache.flink.runtime.state.StateBackendBuilder<ForStKeyedStateBackend<K>,org.apache.flink.runtime.state.BackendBuildingException>

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

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.flink.core.fs.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, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int numberOfKeyGroups, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, org.apache.flink.api.common.ExecutionConfig executionConfig, ForStPriorityQueueConfig priorityQueueConfig, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, org.apache.flink.metrics.MetricGroup metricGroup, org.apache.flink.runtime.state.StateBackend.CustomInitializationMetrics customInitializationMetrics, Collection<org.apache.flink.runtime.state.KeyedStateHandle> stateHandles, org.apache.flink.core.fs.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 org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry

Constructor Detail

ForStKeyedStateBackendBuilder

public ForStKeyedStateBackendBuilder(String operatorIdentifier,
                                     ClassLoader userCodeClassLoader,
                                     ForStResourceContainer optionsContainer,
                                     Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
                                     org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer,
                                     int numberOfKeyGroups,
                                     org.apache.flink.runtime.state.KeyGroupRange keyGroupRange,
                                     org.apache.flink.api.common.ExecutionConfig executionConfig,
                                     ForStPriorityQueueConfig priorityQueueConfig,
                                     org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider,
                                     org.apache.flink.metrics.MetricGroup metricGroup,
                                     org.apache.flink.runtime.state.StateBackend.CustomInitializationMetrics customInitializationMetrics,
                                     @Nonnull
                                     Collection<org.apache.flink.runtime.state.KeyedStateHandle> stateHandles,
                                     org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry)

Method Detail

build

public ForStKeyedStateBackend<K> build()
                                throws org.apache.flink.runtime.state.BackendBuildingException

Specified by:

build in interface org.apache.flink.runtime.state.StateBackendBuilder<ForStKeyedStateBackend<K>,org.apache.flink.runtime.state.BackendBuildingException>

Throws:

org.apache.flink.runtime.state.BackendBuildingException