K
- The data type that the key serializer serializes.public class HeapKeyedStateBackendBuilder<K> extends AbstractKeyedStateBackendBuilder<K>
HeapKeyedStateBackend
which handles all necessary initializations and
clean ups.cancelStreamRegistry, executionConfig, keyGroupCompressionDecorator, keyGroupRange, keySerializerProvider, kvStateRegistry, logger, numberOfKeyGroups, restoreStateHandles, ttlTimeProvider, userCodeClassLoader
Constructor and Description |
---|
HeapKeyedStateBackendBuilder(TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
ClassLoader userCodeClassLoader,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
ExecutionConfig executionConfig,
TtlTimeProvider ttlTimeProvider,
Collection<KeyedStateHandle> stateHandles,
StreamCompressionDecorator keyGroupCompressionDecorator,
LocalRecoveryConfig localRecoveryConfig,
HeapPriorityQueueSetFactory priorityQueueSetFactory,
boolean asynchronousSnapshots,
CloseableRegistry cancelStreamRegistry) |
public HeapKeyedStateBackendBuilder(TaskKvStateRegistry kvStateRegistry, TypeSerializer<K> keySerializer, ClassLoader userCodeClassLoader, int numberOfKeyGroups, KeyGroupRange keyGroupRange, ExecutionConfig executionConfig, TtlTimeProvider ttlTimeProvider, @Nonnull Collection<KeyedStateHandle> stateHandles, StreamCompressionDecorator keyGroupCompressionDecorator, LocalRecoveryConfig localRecoveryConfig, HeapPriorityQueueSetFactory priorityQueueSetFactory, boolean asynchronousSnapshots, CloseableRegistry cancelStreamRegistry)
public HeapKeyedStateBackend<K> build() throws BackendBuildingException
BackendBuildingException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.