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.ExtractJoinFields	A SimpleFunction to extract join fields from the specified row.
BeamJoinTransforms.JoinAsLookup	Transform to execute Join as Lookup.
BeamJoinTransforms.JoinParts2WholeRow	A SimpleFunction to combine two rows into one.
BeamJoinTransforms.SideInputJoinDoFn	A DoFn which implement the sideInput-JOIN.
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.