public static class BeamAggregationTransforms.AggregationGroupByKeyFn extends java.lang.Object implements SerializableFunction<Row,Row>
Constructor and Description |
---|
AggregationGroupByKeyFn(Schema keySchema,
int windowFieldIdx,
org.apache.calcite.util.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(Schema keySchema, int windowFieldIdx, org.apache.calcite.util.ImmutableBitSet groupSet)
public Row apply(Row input)
SerializableFunction
apply
in interface SerializableFunction<Row,Row>