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 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 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 an empty list is passed in, the state value will be null
Null value passed in or any null value in list is not allowed.
void 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 an empty list is passed in, the state value remains unchanged
Null value passed in or any null value in list is not allowed.
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.