public abstract class AbstractKeyedStateBackendBuilder<K> extends Object implements StateBackendBuilder<AbstractKeyedStateBackend,BackendBuildingException>
StateBackendBuilder
interface.Modifier and Type | Field and Description |
---|---|
protected CloseableRegistry |
cancelStreamRegistry |
protected ExecutionConfig |
executionConfig |
protected StreamCompressionDecorator |
keyGroupCompressionDecorator |
protected KeyGroupRange |
keyGroupRange |
protected StateSerializerProvider<K> |
keySerializerProvider |
protected TaskKvStateRegistry |
kvStateRegistry |
protected LatencyTrackingStateConfig |
latencyTrackingStateConfig |
protected org.slf4j.Logger |
logger |
protected int |
numberOfKeyGroups |
protected Collection<KeyedStateHandle> |
restoreStateHandles |
protected TtlTimeProvider |
ttlTimeProvider |
protected ClassLoader |
userCodeClassLoader |
Constructor and Description |
---|
AbstractKeyedStateBackendBuilder(TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
ClassLoader userCodeClassLoader,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
ExecutionConfig executionConfig,
TtlTimeProvider ttlTimeProvider,
LatencyTrackingStateConfig latencyTrackingStateConfig,
Collection<KeyedStateHandle> stateHandles,
StreamCompressionDecorator keyGroupCompressionDecorator,
CloseableRegistry cancelStreamRegistry) |
protected final org.slf4j.Logger logger
protected final TaskKvStateRegistry kvStateRegistry
protected final StateSerializerProvider<K> keySerializerProvider
protected final ClassLoader userCodeClassLoader
protected final int numberOfKeyGroups
protected final KeyGroupRange keyGroupRange
protected final ExecutionConfig executionConfig
protected final TtlTimeProvider ttlTimeProvider
protected final LatencyTrackingStateConfig latencyTrackingStateConfig
protected final StreamCompressionDecorator keyGroupCompressionDecorator
protected final Collection<KeyedStateHandle> restoreStateHandles
protected final CloseableRegistry cancelStreamRegistry
public AbstractKeyedStateBackendBuilder(TaskKvStateRegistry kvStateRegistry, TypeSerializer<K> keySerializer, ClassLoader userCodeClassLoader, int numberOfKeyGroups, KeyGroupRange keyGroupRange, ExecutionConfig executionConfig, TtlTimeProvider ttlTimeProvider, LatencyTrackingStateConfig latencyTrackingStateConfig, @Nonnull Collection<KeyedStateHandle> stateHandles, StreamCompressionDecorator keyGroupCompressionDecorator, CloseableRegistry cancelStreamRegistry)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.