Modifier and Type | Method and Description |
---|---|
void |
SharedBuffer.migrateOldState(KeyedStateBackend<?> stateBackend,
ValueState<NFAState> computationStates) |
Modifier and Type | Class and Description |
---|---|
class |
RocksDBKeyedStateBackend<K>
An
AbstractKeyedStateBackend that stores its state in RocksDB and serializes
state to streams provided by a CheckpointStreamFactory
upon checkpointing. |
Modifier and Type | Interface and Description |
---|---|
interface |
CheckpointableKeyedStateBackend<K>
Interface that combines both, the
KeyedStateBackend interface, which encapsulates methods
responsible for keyed state management and the Snapshotable which tells the system how to
snapshot the underlying state. |
interface |
TestableKeyedStateBackend<K>
A keyed state backend interface for internal testing purpose.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractKeyedStateBackend<K>
Base implementation of KeyedStateBackend.
|
Modifier and Type | Field and Description |
---|---|
protected KeyedStateBackend<?> |
DefaultKeyedStateStore.keyedStateBackend |
Modifier and Type | Method and Description |
---|---|
default KeyedStateBackend<K> |
TestableKeyedStateBackend.getDelegatedKeyedStateBackend(boolean recursive) |
Constructor and Description |
---|
DefaultKeyedStateStore(KeyedStateBackend<?> keyedStateBackend,
ExecutionConfig executionConfig) |
Modifier and Type | Class and Description |
---|---|
class |
HeapKeyedStateBackend<K>
A
AbstractKeyedStateBackend that keeps state on the Java Heap and will serialize state to
streams provided by a CheckpointStreamFactory upon checkpointing. |
Modifier and Type | Method and Description |
---|---|
static <K,N,SV,TTLSV,S extends State,IS extends S> |
TtlStateFactory.createStateAndWrapWithTtlIfEnabled(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc,
KeyedStateBackend<K> stateBackend,
TtlTimeProvider timeProvider) |
Constructor and Description |
---|
MultiStateKeyIterator(List<? extends StateDescriptor<?,?>> descriptors,
KeyedStateBackend<K> backend) |
Modifier and Type | Method and Description |
---|---|
KeyedStateBackend<KEY> |
StateReaderOperator.getKeyedStateBackend() |
Modifier and Type | Method and Description |
---|---|
void |
StateReaderOperator.setup(ExecutionConfig executionConfig,
KeyedStateBackend<KEY> keyKeyedStateBackend,
InternalTimeServiceManager<KEY> timerServiceManager,
SavepointRuntimeContext ctx) |
Modifier and Type | Class and Description |
---|---|
class |
ChangelogKeyedStateBackend<K>
A
KeyedStateBackend that keeps state on the underlying delegated keyed state backend as
well as on the state change log. |
Modifier and Type | Method and Description |
---|---|
KeyedStateBackend<K> |
ChangelogKeyedStateBackend.getDelegatedKeyedStateBackend(boolean recursive) |
Modifier and Type | Method and Description |
---|---|
<K> KeyedStateBackend<K> |
AbstractStreamOperator.getKeyedStateBackend() |
<K> KeyedStateBackend<K> |
AbstractStreamOperatorV2.getKeyedStateBackend() |
<K> KeyedStateBackend<K> |
StreamOperatorStateHandler.getKeyedStateBackend() |
Constructor and Description |
---|
TimerRegistration(KeyedStateBackend<Row> keyedStateBackend,
InternalTimerService internalTimerService,
KeyContext keyContext,
TypeSerializer namespaceSerializer,
TypeSerializer<Row> timerDataSerializer) |
Modifier and Type | Class and Description |
---|---|
class |
BatchExecutionKeyedStateBackend<K>
A
CheckpointableKeyedStateBackend which keeps values for a single key at a time. |
Constructor and Description |
---|
BeamDataStreamPythonFunctionRunner(String taskName,
ProcessPythonEnvironmentManager environmentManager,
String headOperatorFunctionUrn,
List<FlinkFnApi.UserDefinedDataStreamFunction> userDefinedDataStreamFunctions,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> stateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
TimerRegistration timerRegistration,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor timerCoderDescriptor) |
BeamPythonFunctionRunner(String taskName,
ProcessPythonEnvironmentManager environmentManager,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
TimerRegistration timerRegistration,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
Modifier and Type | Method and Description |
---|---|
static <K> boolean |
PythonOperatorUtils.inBatchExecutionMode(KeyedStateBackend<K> stateBackend) |
static <K> void |
PythonOperatorUtils.setCurrentKeyForStreaming(KeyedStateBackend<K> stateBackend,
K currentKey)
Set the current key for streaming operator.
|
Constructor and Description |
---|
AbstractPerWindowStateStore(KeyedStateBackend<?> keyedStateBackend,
ExecutionConfig executionConfig) |
MergingWindowStateStore(KeyedStateBackend<?> keyedStateBackend,
ExecutionConfig executionConfig) |
PerWindowStateStore(KeyedStateBackend<?> keyedStateBackend,
ExecutionConfig executionConfig) |
Constructor and Description |
---|
PerWindowStateDataViewStore(KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> windowSerializer,
RuntimeContext runtimeContext) |
Modifier and Type | Method and Description |
---|---|
WindowBuffer |
WindowBuffer.Factory.create(Object operatorOwner,
MemoryManager memoryManager,
long memorySize,
RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime,
java.time.ZoneId shiftTimeZone)
Creates a
WindowBuffer that buffers elements in memory before flushing. |
WindowBuffer |
RecordsWindowBuffer.Factory.create(Object operatorOwner,
MemoryManager memoryManager,
long memorySize,
RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime,
java.time.ZoneId shiftTimeZone) |
Modifier and Type | Method and Description |
---|---|
RecordsCombiner |
AggCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime) |
RecordsCombiner |
GlobalAggCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime) |
Modifier and Type | Method and Description |
---|---|
RecordsCombiner |
RowTimeDeduplicateRecordsCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime) |
Modifier and Type | Method and Description |
---|---|
RecordsCombiner |
TopNRecordsCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime) |
Modifier and Type | Method and Description |
---|---|
RecordsCombiner |
RecordsCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime)
Creates a
RecordsCombiner that can combine buffered data into states. |
Modifier and Type | Method and Description |
---|---|
KeyedStateBackend<RowData> |
SlicingWindowProcessor.Context.getKeyedStateBackend()
Returns the current
KeyedStateBackend . |
Modifier and Type | Method and Description |
---|---|
static BeamTablePythonFunctionRunner |
BeamTablePythonFunctionRunner.stateful(String taskName,
ProcessPythonEnvironmentManager environmentManager,
String functionUrn,
com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
Constructor and Description |
---|
BeamTablePythonFunctionRunner(String taskName,
ProcessPythonEnvironmentManager environmentManager,
String functionUrn,
com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.