org.apache.beam.sdk.state

Interface GroupingState<InputT,OutputT>

Type Parameters:

InputT - the type of values added to the state

OutputT - the type of value extracted from the state

All Superinterfaces:

ReadableState<OutputT>, State

All Known Subinterfaces:

BagState<T>, CombiningState<InputT,AccumT,OutputT>, SetState<T>, WatermarkHoldState

@Experimental(value=STATE)
public interface GroupingState<InputT,OutputT>
extends ReadableState<OutputT>, State

A ReadableState cell that combines multiple input values and outputs a single value of a different type.

This generalizes GroupByKey and Combine styles of grouping.

Method Summary

Modifier and Type	Method and Description
void	add(InputT value) Add a value to the buffer.
ReadableState<java.lang.Boolean>	isEmpty() Return true if this state is empty.
GroupingState<InputT,OutputT>	readLater() Indicate that the value will be read later.

Methods inherited from interface org.apache.beam.sdk.state.ReadableState

read

Methods inherited from interface org.apache.beam.sdk.state.State

clear

Method Detail

add

void add(InputT value)

Add a value to the buffer.

isEmpty

ReadableState<java.lang.Boolean> isEmpty()

Return true if this state is empty.

readLater

GroupingState<InputT,OutputT> readLater()

Description copied from interface: ReadableState

Indicate that the value will be read later.

This allows an implementation to start an asynchronous prefetch or to include this state in the next batch of reads.

Specified by:

readLater in interface ReadableState<OutputT>

Returns:

this for convenient chaining