Interface State
-
- All Known Subinterfaces:
AggregatingState<IN,OUT>
,AppendingState<IN,OUT,SYNCOUT>
,InternalAggregatingState<K,N,IN,ACC,OUT>
,InternalAppendingState<K,N,IN,SV,OUT,SYNCOUT>
,InternalKeyedState<K,N,V>
,InternalListState<K,N,V>
,InternalMapState<K,N,UK,UV>
,InternalMergingState<K,N,IN,SV,OUT,SYNCOUT>
,InternalReducingState<K,N,T>
,InternalValueState<K,N,V>
,ListState<T>
,MapState<UK,UV>
,MergingState<IN,OUT,SYNCOUT>
,ReducingState<T>
,ValueState<T>
- All Known Implementing Classes:
AbstractAggregatingState
,AbstractKeyedState
,AbstractListState
,AbstractMapState
,AbstractReducingState
,AbstractValueState
,AggregatingStateAdaptor
,ForStAggregatingState
,ForStListState
,ForStMapState
,ForStReducingState
,ForStValueState
,ListStateAdaptor
,MapStateAdaptor
,MergingStateAdaptor
,ReducingStateAdaptor
,StateAdaptor
,ValueStateAdaptor
@Experimental public interface State
Interface that different types of partitioned state must implement.The state is only accessible by functions applied on a
KeyedStream
. The key is automatically supplied by the system, so the function always sees the value mapped to the key of the current element. That way, the system can handle stream and state partitioning consistently together.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StateFuture<Void>
asyncClear()
Removes the value mapped under the current key asynchronously.void
clear()
Removes the value mapped under the current key.
-
-
-
Method Detail
-
asyncClear
StateFuture<Void> asyncClear()
Removes the value mapped under the current key asynchronously.
-
clear
void clear()
Removes the value mapped under the current key.
-
-