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