org.apache.beam.sdk.extensions.sql.impl.transform

Class BeamAggregationTransforms

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.transform.BeamAggregationTransforms

All Implemented Interfaces:

java.io.Serializable

public class BeamAggregationTransforms
extends java.lang.Object
implements java.io.Serializable

Collections of PTransform and DoFn used to perform GROUP-BY operation.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BeamAggregationTransforms.AggregationAccumulator A class to holder varied accumulator objects.
static class	BeamAggregationTransforms.AggregationAccumulatorCoder Coder for BeamAggregationTransforms.AggregationAccumulator.
static class	BeamAggregationTransforms.AggregationAdaptor An adaptor class to invoke Calcite UDAF instances in Beam CombineFn.
static class	BeamAggregationTransforms.AggregationGroupByKeyFn extract group-by fields.
static class	BeamAggregationTransforms.MergeAggregationRecord Merge KV to single record.
static class	BeamAggregationTransforms.WindowTimestampFn Assign event timestamp.

Constructor Summary

Constructors

Constructor and Description
BeamAggregationTransforms()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamAggregationTransforms

public BeamAggregationTransforms()