org.apache.flink.contrib.streaming.state

Class RocksDBKeyedStateBackendBuilder<K>

java.lang.Object

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

org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder<K>

Type Parameters:

K - The data type that the key serializer serializes.

All Implemented Interfaces:

StateBackendBuilder<AbstractKeyedStateBackend,BackendBuildingException>

public class RocksDBKeyedStateBackendBuilder<K>
extends AbstractKeyedStateBackendBuilder<K>

Builder class for RocksDBKeyedStateBackend 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, numberOfKeyGroups, restoreStateHandles, ttlTimeProvider, userCodeClassLoader

Constructor Summary

Constructors

Constructor and Description

RocksDBKeyedStateBackendBuilder(String operatorIdentifier, ClassLoader userCodeClassLoader, File instanceBasePath, RocksDBResourceContainer optionsContainer, java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, TaskKvStateRegistry kvStateRegistry, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, ExecutionConfig executionConfig, LocalRecoveryConfig localRecoveryConfig, RocksDBStateBackend.PriorityQueueStateType priorityQueueStateType, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, StreamCompressionDecorator keyGroupCompressionDecorator, CloseableRegistry cancelStreamRegistry)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksDBKeyedStateBackendBuilder

public RocksDBKeyedStateBackendBuilder(String operatorIdentifier,
                                       ClassLoader userCodeClassLoader,
                                       File instanceBasePath,
                                       RocksDBResourceContainer optionsContainer,
                                       java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
                                       TaskKvStateRegistry kvStateRegistry,
                                       TypeSerializer<K> keySerializer,
                                       int numberOfKeyGroups,
                                       KeyGroupRange keyGroupRange,
                                       ExecutionConfig executionConfig,
                                       LocalRecoveryConfig localRecoveryConfig,
                                       RocksDBStateBackend.PriorityQueueStateType priorityQueueStateType,
                                       TtlTimeProvider ttlTimeProvider,
                                       MetricGroup metricGroup,
                                       @Nonnull
                                       Collection<KeyedStateHandle> stateHandles,
                                       StreamCompressionDecorator keyGroupCompressionDecorator,
                                       CloseableRegistry cancelStreamRegistry)

Method Detail

build

public RocksDBKeyedStateBackend<K> build()
                                  throws BackendBuildingException

Throws:

BackendBuildingException