public static class BeamAggregationTransforms.AggregationGroupByKeyFn extends java.lang.Object implements SerializableFunction<Row,Row>
Constructor and Description |
---|
AggregationGroupByKeyFn(int windowFieldIdx,
ImmutableBitSet groupSet) |
Modifier and Type | Method and Description |
---|---|
Row |
apply(Row input)
Returns the result of invoking this function on the given input.
|
public AggregationGroupByKeyFn(int windowFieldIdx, ImmutableBitSet groupSet)
public Row apply(Row input)
SerializableFunction
apply
in interface SerializableFunction<Row,Row>