K
- The data type that the key serializer serializes.public class ForStKeyedStateBackendBuilder<K> extends Object implements StateBackendBuilder<ForStKeyedStateBackend<K>,BackendBuildingException>
ForStKeyedStateBackend
which handles all necessary initializations and
cleanups.Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
logger |
Constructor and Description |
---|
ForStKeyedStateBackendBuilder(ForStResourceContainer optionsContainer,
java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
TypeSerializer<K> keySerializer,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles) |
public ForStKeyedStateBackendBuilder(ForStResourceContainer optionsContainer, java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, TypeSerializer<K> keySerializer, MetricGroup metricGroup, @Nonnull Collection<KeyedStateHandle> stateHandles)
public ForStKeyedStateBackend<K> build() throws BackendBuildingException
build
in interface StateBackendBuilder<ForStKeyedStateBackend<K>,BackendBuildingException>
BackendBuildingException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.