K
- The type of key the state is associated toN
- The type of the namespaceT
- The type of elements in the listpublic interface InternalListState<K,N,T> extends InternalMergingState<K,N,T,List<T>,Iterable<T>>, ListState<T>
ListState
in the internal state type hierarchy.
See InternalKvState
for a description of the internal state hierarchy.
InternalKvState.StateIncrementalVisitor<K,N,V>
Modifier and Type | Method and Description |
---|---|
void |
addAll(List<T> values)
Updates the operator state accessible by
AppendingState.get() by adding the given values
to existing list of values. |
void |
update(List<T> values)
Updates the operator state accessible by
AppendingState.get() by updating existing values to
to the given list of values. |
mergeNamespaces
getInternal, updateInternal
getKeySerializer, getNamespaceSerializer, getSerializedValue, getStateIncrementalVisitor, getValueSerializer, setCurrentNamespace
add, get
void update(List<T> values) throws Exception
AppendingState.get()
by updating existing values to
to the given list of values. The next time AppendingState.get()
is called (for the same state
partition) the returned state will represent the updated list.
If `null` or an empty list is passed in, the state value will be nullvoid addAll(List<T> values) throws Exception
AppendingState.get()
by adding the given values
to existing list of values. The next time AppendingState.get()
is called (for the same state
partition) the returned state will represent the updated list.
If `null` or an empty list is passed in, the state value remains unchangedCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.