public static class BeamAggregationTransforms.MergeAggregationRecord extends DoFn<KV<BeamRecord,BeamRecord>,BeamRecord>
DoFn.BoundedPerElement, DoFn.FinishBundle, DoFn.FinishBundleContext, DoFn.GetInitialRestriction, DoFn.GetRestrictionCoder, DoFn.NewTracker, DoFn.OnTimer, DoFn.OnTimerContext, DoFn.OutputReceiver<T>, DoFn.ProcessContext, DoFn.ProcessContinuation, DoFn.ProcessElement, DoFn.RequiresStableInput, DoFn.Setup, DoFn.SplitRestriction, DoFn.StartBundle, DoFn.StartBundleContext, DoFn.StateId, DoFn.Teardown, DoFn.TimerId, DoFn.UnboundedPerElement, DoFn.WindowedContext
Constructor and Description |
---|
MergeAggregationRecord(BeamRecordSqlType outRowType,
java.util.List<AggregateCall> aggList,
int windowStartFieldIdx) |
Modifier and Type | Method and Description |
---|---|
void |
processElement(DoFn.ProcessContext c,
BoundedWindow window) |
getAllowedTimestampSkew, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData, prepareForProcessing
public MergeAggregationRecord(BeamRecordSqlType outRowType, java.util.List<AggregateCall> aggList, int windowStartFieldIdx)
@DoFn.ProcessElement public void processElement(DoFn.ProcessContext c, BoundedWindow window)