S
- the type of an operator state partition.public final class PartitionableListState<S> extends Object implements ListState<S>
Modifier and Type | Method and Description |
---|---|
void |
add(S value)
Updates the operator state accessible by
AppendingState.get() by adding the given value
to the list of values. |
void |
addAll(List<S> values)
Updates the operator state accessible by
AppendingState.get() by adding the given values
to existing list of values. |
void |
clear()
Removes the value mapped under the current key.
|
PartitionableListState<S> |
deepCopy() |
Iterable<S> |
get()
Returns the current value for the state.
|
RegisteredOperatorStateBackendMetaInfo<S> |
getStateMetaInfo() |
void |
setStateMetaInfo(RegisteredOperatorStateBackendMetaInfo<S> stateMetaInfo) |
String |
toString() |
void |
update(List<S> values)
Updates the operator state accessible by
AppendingState.get() by updating existing values to
to the given list of values. |
long[] |
write(FSDataOutputStream out) |
public void setStateMetaInfo(RegisteredOperatorStateBackendMetaInfo<S> stateMetaInfo)
public RegisteredOperatorStateBackendMetaInfo<S> getStateMetaInfo()
public PartitionableListState<S> deepCopy()
public void clear()
State
public Iterable<S> get()
AppendingState
NOTE TO IMPLEMENTERS: if the state is empty, then this method
should return null
.
get
in interface AppendingState<S,Iterable<S>>
null
if the state is empty.public void add(S value)
AppendingState
AppendingState.get()
by adding the given value
to the 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 is passed in, the state value will remain unchanged.
add
in interface AppendingState<S,Iterable<S>>
value
- The new value for the state.public long[] write(FSDataOutputStream out) throws IOException
IOException
public void update(List<S> values)
ListState
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 null.
public void addAll(List<S> values)
ListState
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 unchanged.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.