org.apache.beam.runners.spark.structuredstreaming.aggregators

Interface NamedAggregators.State<InputT,InterT,OutputT>

Type Parameters:

InputT - Input data type

InterT - Intermediate data type (useful for averages)

OutputT - Output data type

All Superinterfaces:

java.io.Serializable

Enclosing class:

NamedAggregators

public static interface NamedAggregators.State<InputT,InterT,OutputT>
extends java.io.Serializable

Method Summary

Modifier and Type	Method and Description
InterT	current()
Combine.CombineFn<InputT,InterT,OutputT>	getCombineFn()
NamedAggregators.State<InputT,InterT,OutputT>	merge(NamedAggregators.State<InputT,InterT,OutputT> other)
OutputT	render()
void	update(InputT element)

Method Detail

update

void update(InputT element)

Parameters:

element - new element to update state

merge

NamedAggregators.State<InputT,InterT,OutputT> merge(NamedAggregators.State<InputT,InterT,OutputT> other)

current

InterT current()

render

OutputT render()

getCombineFn

Combine.CombineFn<InputT,InterT,OutputT> getCombineFn()