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:

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

public class ForStSyncKeyedStateBackendBuilder<K>
extends org.apache.flink.runtime.state.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, ForStResourceContainer optionsContainer, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, org.apache.flink.runtime.query.TaskKvStateRegistry kvStateRegistry, 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, org.apache.flink.runtime.state.LocalRecoveryConfig localRecoveryConfig, ForStPriorityQueueConfig priorityQueueConfig, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, org.apache.flink.runtime.state.metrics.LatencyTrackingStateConfig latencyTrackingStateConfig, 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.runtime.state.StreamCompressionDecorator keyGroupCompressionDecorator, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry)

Method Summary

Modifier and Type	Method	Description
ForStSyncKeyedStateBackend<K>	build()
ForStSyncKeyedStateBackendBuilder<K>	setEnableIncrementalCheckpointing(boolean enableIncrementalCheckpointing)
ForStSyncKeyedStateBackendBuilder<K>	setNativeMetricOptions(ForStNativeMetricOptions nativeMetricOptions)
ForStSyncKeyedStateBackendBuilder<K>	setOverlapFractionThreshold(double overlapFractionThreshold)
ForStSyncKeyedStateBackendBuilder<K>	setRecoveryClaimMode(org.apache.flink.core.execution.RecoveryClaimMode recoveryClaimMode)
ForStSyncKeyedStateBackendBuilder<K>	setRescalingUseDeleteFilesInRange(boolean rescalingUseDeleteFilesInRange)
ForStSyncKeyedStateBackendBuilder<K>	setUseIngestDbRestoreMode(boolean useIngestDbRestoreMode)
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,
                                         ForStResourceContainer optionsContainer,
                                         Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
                                         org.apache.flink.runtime.query.TaskKvStateRegistry kvStateRegistry,
                                         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,
                                         org.apache.flink.runtime.state.LocalRecoveryConfig localRecoveryConfig,
                                         ForStPriorityQueueConfig priorityQueueConfig,
                                         org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider,
                                         org.apache.flink.runtime.state.metrics.LatencyTrackingStateConfig latencyTrackingStateConfig,
                                         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.runtime.state.StreamCompressionDecorator keyGroupCompressionDecorator,
                                         org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry)

Method Detail

setEnableIncrementalCheckpointing

public ForStSyncKeyedStateBackendBuilder<K> setEnableIncrementalCheckpointing(boolean enableIncrementalCheckpointing)

setNativeMetricOptions

public ForStSyncKeyedStateBackendBuilder<K> setNativeMetricOptions(ForStNativeMetricOptions nativeMetricOptions)

setWriteBatchSize

public ForStSyncKeyedStateBackendBuilder<K> setWriteBatchSize(long writeBatchSize)

build

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

Throws:

org.apache.flink.runtime.state.BackendBuildingException

setOverlapFractionThreshold

public ForStSyncKeyedStateBackendBuilder<K> setOverlapFractionThreshold(double overlapFractionThreshold)

setUseIngestDbRestoreMode

public ForStSyncKeyedStateBackendBuilder<K> setUseIngestDbRestoreMode(boolean useIngestDbRestoreMode)

setRescalingUseDeleteFilesInRange

public ForStSyncKeyedStateBackendBuilder<K> setRescalingUseDeleteFilesInRange(boolean rescalingUseDeleteFilesInRange)

setRecoveryClaimMode

public ForStSyncKeyedStateBackendBuilder<K> setRecoveryClaimMode(org.apache.flink.core.execution.RecoveryClaimMode recoveryClaimMode)