@Experimental public interface StateManager
Modifier and Type | Method and Description |
---|---|
<K> K |
getCurrentKey()
Get the key of current record.
|
<IN,ACC,OUT> |
getState(AggregatingStateDeclaration<IN,ACC,OUT> stateDeclaration)
Get the specific aggregating state.
|
<K,V> Optional<BroadcastState<K,V>> |
getState(BroadcastStateDeclaration<K,V> stateDeclaration)
Get the specific broadcast state.
|
<T> Optional<ListState<T>> |
getState(ListStateDeclaration<T> stateDeclaration)
Get the specific list state.
|
<K,V> Optional<MapState<K,V>> |
getState(MapStateDeclaration<K,V> stateDeclaration)
Get the specific map state.
|
<T> Optional<ReducingState<T>> |
getState(ReducingStateDeclaration<T> stateDeclaration)
Get the specific reducing state.
|
<T> Optional<ValueState<T>> |
getState(ValueStateDeclaration<T> stateDeclaration)
Get the specific value state.
|
<K> K getCurrentKey() throws UnsupportedOperationException
UnsupportedOperationException
- if the key can not be extracted for this function, for
instance, get the key from a non-keyed partition stream.<T> Optional<ListState<T>> getState(ListStateDeclaration<T> stateDeclaration) throws Exception
stateDeclaration
- of this state.Exception
<T> Optional<ValueState<T>> getState(ValueStateDeclaration<T> stateDeclaration) throws Exception
stateDeclaration
- of this state.Exception
<K,V> Optional<MapState<K,V>> getState(MapStateDeclaration<K,V> stateDeclaration) throws Exception
stateDeclaration
- of this state.Exception
<T> Optional<ReducingState<T>> getState(ReducingStateDeclaration<T> stateDeclaration) throws Exception
stateDeclaration
- of this state.Exception
<IN,ACC,OUT> Optional<AggregatingState<IN,OUT>> getState(AggregatingStateDeclaration<IN,ACC,OUT> stateDeclaration) throws Exception
stateDeclaration
- of this state.Exception
<K,V> Optional<BroadcastState<K,V>> getState(BroadcastStateDeclaration<K,V> stateDeclaration) throws Exception
stateDeclaration
- of this state.Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.