Package org.apache.beam.sdk.extensions.sql.impl.transform

PTransform used in a BeamSql pipeline.

Class Summary

Class	Description
BeamBuiltinAggregations	Built-in aggregations functions for COUNT/MAX/MIN/SUM/AVG/VAR_POP/VAR_SAMP.
BeamBuiltinAggregations.BitXOr<T extends java.lang.Number>
BeamBuiltinAnalyticFunctions	Built-in Analytic Functions for the aggregation analytics functionality.
BeamBuiltinAnalyticFunctions.PositionAwareCombineFn<InputT,AccumT,OutputT>
BeamJoinTransforms	Collections of PTransform and DoFn used to perform JOIN operation.
BeamJoinTransforms.JoinAsLookup	Transform to execute Join as Lookup.
BeamSetOperatorsTransforms	Collections of PTransform and DoFn used to perform Set operations.
BeamSetOperatorsTransforms.BeamSqlRow2KvFn	Transform a BeamSqlRow to a KV<BeamSqlRow, BeamSqlRow>.
BeamSetOperatorsTransforms.SetOperatorFilteringDoFn	Filter function used for Set operators.
BeamSqlOutputToConsoleFn	A test PTransform to display output in console.