org.apache.flink.runtime.state

Class PartitionableListState<S>

java.lang.Object

org.apache.flink.runtime.state.PartitionableListState<S>

Type Parameters:

S - the type of an operator state partition.

All Implemented Interfaces:

AppendingState<S,Iterable<S>>, ListState<S>, MergingState<S,Iterable<S>>, State

public final class PartitionableListState<S>
extends Object
implements ListState<S>

Implementation of operator list state.

Method Summary

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.
ArrayListSerializer<S>	getInternalListCopySerializer()
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 the given list of values.
long[]	write(FSDataOutputStream out)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

setStateMetaInfo

public void setStateMetaInfo(RegisteredOperatorStateBackendMetaInfo<S> stateMetaInfo)

getStateMetaInfo

public RegisteredOperatorStateBackendMetaInfo<S> getStateMetaInfo()

deepCopy

public PartitionableListState<S> deepCopy()

clear

public void clear()

Description copied from interface: State

Removes the value mapped under the current key.

Specified by:

clear in interface State

get

public Iterable<S> get()

Description copied from interface: AppendingState

Returns the current value for the state. When the state is not partitioned the returned value is the same for all inputs in a given operator instance. If state partitioning is applied, the value returned depends on the current operator input, as the operator maintains an independent state for each partition.

NOTE TO IMPLEMENTERS: if the state is empty, then this method should return null.

Specified by:

get in interface AppendingState<S,Iterable<S>>

Returns:

The operator state value corresponding to the current input or null if the state is empty.

add

public void add(S value)

Description copied from interface: AppendingState

Updates the operator state accessible by 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.

Specified by:

add in interface AppendingState<S,Iterable<S>>

Parameters:

value - The new value for the state.

toString

public String toString()

Overrides:

toString in class Object

write

public long[] write(FSDataOutputStream out)
             throws IOException

Throws:

IOException

update

public void update(List<S> values)

Description copied from interface: ListState

Updates the operator state accessible by 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 null or an empty list is passed in, the state value will be null.

Specified by:

update in interface ListState<S>

Parameters:

values - The new values for the state.

addAll

public void addAll(List<S> values)

Description copied from interface: ListState

Updates the operator state accessible by 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.

Specified by:

addAll in interface ListState<S>

Parameters:

values - The new values to be added to the state.

getInternalListCopySerializer

@VisibleForTesting
public ArrayListSerializer<S> getInternalListCopySerializer()