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.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor	Description
ForStKeyedStateBackendBuilder(ForStResourceContainer optionsContainer, java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int numberOfKeyGroups, org.apache.flink.metrics.MetricGroup metricGroup, Collection<org.apache.flink.runtime.state.KeyedStateHandle> stateHandles)

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

Constructor Detail

ForStKeyedStateBackendBuilder

public ForStKeyedStateBackendBuilder(ForStResourceContainer optionsContainer,
                                     java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
                                     org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer,
                                     int numberOfKeyGroups,
                                     org.apache.flink.metrics.MetricGroup metricGroup,
                                     @Nonnull
                                     Collection<org.apache.flink.runtime.state.KeyedStateHandle> stateHandles)

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