com.google.cloud.dataflow.sdk.util.state

Interface MergeableState<InputT,OutputT>

Type Parameters:

InputT - The type of values put into the buffer.

OutputT - The type of values extracted from the buffer.

All Superinterfaces:

State

All Known Subinterfaces:

BagState<T>, CombiningValueState<InputT,OutputT>, CombiningValueStateInternal<InputT,AccumT,OutputT>, WatermarkStateInternal

public interface MergeableState<InputT,OutputT>
extends State

State that is automatically mergeable and supports buffering values.

Method Summary

Modifier and Type	Method and Description
void	add(InputT value) Add a value to the buffer.
StateContents<OutputT>	get() Return the StateContents object to use for accessing the contents of the buffer.
StateContents<Boolean>	isEmpty() Return true if this state is empty.

Methods inherited from interface com.google.cloud.dataflow.sdk.util.state.State

clear

Method Detail

add

void add(InputT value)

Add a value to the buffer.

get

StateContents<OutputT> get()

Return the StateContents object to use for accessing the contents of the buffer.

isEmpty

StateContents<Boolean> isEmpty()

Return true if this state is empty.