T
- Type of values that this list state keeps.@PublicEvolving public interface ListState<T> extends MergingState<T,Iterable<T>>
State
interface for partitioned list state in Operations.
The state is accessed and modified by user functions, and checkpointed consistently
by the system as part of the distributed snapshots.
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.
add, get
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.