public class BeamAggregationTransforms
extends java.lang.Object
implements java.io.Serializable
PTransform
and DoFn
used to perform GROUP-BY operation.Modifier and Type | Class and Description |
---|---|
static class |
BeamAggregationTransforms.AggregationAccumulator
A class to holder varied accumulator objects.
|
static class |
BeamAggregationTransforms.AggregationAccumulatorCoder
|
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 and Description |
---|
BeamAggregationTransforms() |