| Package | Description |
|---|---|
| org.apache.storm.streams | |
| org.apache.storm.streams.processors |
| Modifier and Type | Method and Description |
|---|---|
<R> StreamState<K,R> |
PairStream.updateStateByKey(R initialValue,
BiFunction<? super R,? super V,? extends R> stateUpdateFn)
Update the state by applying the given state update function to the previous state of the key and the new value for the key.
|
<R> StreamState<K,R> |
PairStream.updateStateByKey(StateUpdater<? super V,? extends R> stateUpdater)
Update the state by applying the given state update function to the previous state of the key and the new value for the key.
|
| Modifier and Type | Method and Description |
|---|---|
<V> PairStream<T,V> |
Stream.stateQuery(StreamState<T,V> streamState)
Queries the given stream state with the values in this stream as the keys.
|
| Modifier and Type | Method and Description |
|---|---|
StreamState<K,V> |
StateQueryProcessor.getStreamState() |
| Constructor and Description |
|---|
StateQueryProcessor(StreamState<K,V> streamState) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.