Modifier and Type | Method and Description |
---|---|
void |
StatefulWordCounter.initState(KeyValueState<String,Long> state) |
Modifier and Type | Class and Description |
---|---|
class |
HBaseKeyValueState<K,V>
A Hbase based implementation that persists the state in HBase.
|
Modifier and Type | Class and Description |
---|---|
class |
RedisKeyValueState<K,V>
A redis based implementation that persists the state in Redis.
|
Modifier and Type | Class and Description |
---|---|
class |
InMemoryKeyValueState<K,V>
An in-memory implementation of the
State . |
Modifier and Type | Method and Description |
---|---|
void |
UpdateStateByKeyProcessor.initState(KeyValueState<K,R> keyValueState) |
void |
StatefulProcessor.initState(KeyValueState<K,V> keyValueState)
Initialize the state of the processor with the given
KeyValueState . |
void |
StateQueryProcessor.initState(KeyValueState<K,V> keyValueState) |
Constructor and Description |
---|
WindowState(KeyValueState<Long,WindowState.WindowPartition<T>> windowPartitionsState,
KeyValueState<String,Deque<Long>> partitionIdsState,
KeyValueState<String,Optional<?>> windowSystemState,
Supplier<Map<String,Optional<?>>> windowSystemStateSupplier,
long maxEventsInMemory) |
WindowState(KeyValueState<Long,WindowState.WindowPartition<T>> windowPartitionsState,
KeyValueState<String,Deque<Long>> partitionIdsState,
KeyValueState<String,Optional<?>> windowSystemState,
Supplier<Map<String,Optional<?>>> windowSystemStateSupplier,
long maxEventsInMemory) |
WindowState(KeyValueState<Long,WindowState.WindowPartition<T>> windowPartitionsState,
KeyValueState<String,Deque<Long>> partitionIdsState,
KeyValueState<String,Optional<?>> windowSystemState,
Supplier<Map<String,Optional<?>>> windowSystemStateSupplier,
long maxEventsInMemory) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.