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

PTransform used in a BeamSql pipeline.

See: Description

Class Summary

Class	Description
BeamBuiltinAggregations	Built-in aggregations functions for COUNT/MAX/MIN/SUM/AVG/VAR_POP/VAR_SAMP.
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.

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

PTransform used in a BeamSql pipeline.