Package org.apache.flink.state.forst.sync

Class ForStSyncKeyedStateBackendBuilder<K>

java.lang.Object

org.apache.flink.runtime.state.AbstractKeyedStateBackendBuilder<K>

org.apache.flink.state.forst.sync.ForStSyncKeyedStateBackendBuilder<K>

Type Parameters:

K - The data type that the key serializer serializes.

All Implemented Interfaces:

StateBackendBuilder<AbstractKeyedStateBackend<K>,BackendBuildingException>

public class ForStSyncKeyedStateBackendBuilder<K>
extends AbstractKeyedStateBackendBuilder<K>

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

Field Summary

Fields inherited from class org.apache.flink.runtime.state.AbstractKeyedStateBackendBuilder

cancelStreamRegistry, executionConfig, keyGroupCompressionDecorator, keyGroupRange, keySerializerProvider, kvStateRegistry, latencyTrackingStateConfig, logger, numberOfKeyGroups, restoreStateHandles, ttlTimeProvider, userCodeClassLoader

Constructor Summary

Constructors

Constructor

Description

ForStSyncKeyedStateBackendBuilder(String operatorIdentifier, ClassLoader userCodeClassLoader, Path instanceBasePath, ForStResourceContainer optionsContainer, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, TaskKvStateRegistry kvStateRegistry, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, ExecutionConfig executionConfig, LocalRecoveryConfig localRecoveryConfig, ForStPriorityQueueConfig priorityQueueConfig, TtlTimeProvider ttlTimeProvider, LatencyTrackingStateConfig latencyTrackingStateConfig, MetricGroup metricGroup, StateBackend.CustomInitializationMetrics customInitializationMetrics, Collection<KeyedStateHandle> stateHandles, StreamCompressionDecorator keyGroupCompressionDecorator, CloseableRegistry cancelStreamRegistry)

Method Summary

Modifier and Type	Method	Description
ForStSyncKeyedStateBackend<K>	build()
static Path	getInstanceRocksDBPath(Path instanceBasePath)
ForStSyncKeyedStateBackendBuilder<K>	setNativeMetricOptions(ForStNativeMetricOptions nativeMetricOptions)
ForStSyncKeyedStateBackendBuilder<K>	setWriteBatchSize(long writeBatchSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

ForStSyncKeyedStateBackendBuilder

public ForStSyncKeyedStateBackendBuilder(String operatorIdentifier,
                                         ClassLoader userCodeClassLoader,
                                         Path instanceBasePath,
                                         ForStResourceContainer optionsContainer,
                                         Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
                                         TaskKvStateRegistry kvStateRegistry,
                                         TypeSerializer<K> keySerializer,
                                         int numberOfKeyGroups,
                                         KeyGroupRange keyGroupRange,
                                         ExecutionConfig executionConfig,
                                         LocalRecoveryConfig localRecoveryConfig,
                                         ForStPriorityQueueConfig priorityQueueConfig,
                                         TtlTimeProvider ttlTimeProvider,
                                         LatencyTrackingStateConfig latencyTrackingStateConfig,
                                         MetricGroup metricGroup,
                                         StateBackend.CustomInitializationMetrics customInitializationMetrics,
                                         @Nonnull
                                         Collection<KeyedStateHandle> stateHandles,
                                         StreamCompressionDecorator keyGroupCompressionDecorator,
                                         CloseableRegistry cancelStreamRegistry)

Method Detail

setNativeMetricOptions

public ForStSyncKeyedStateBackendBuilder<K> setNativeMetricOptions(ForStNativeMetricOptions nativeMetricOptions)

setWriteBatchSize

public ForStSyncKeyedStateBackendBuilder<K> setWriteBatchSize(long writeBatchSize)

getInstanceRocksDBPath

public static Path getInstanceRocksDBPath(Path instanceBasePath)

build

public ForStSyncKeyedStateBackend<K> build()
                                    throws BackendBuildingException

Throws:

BackendBuildingException