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

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

PTransform used in a BeamSql pipeline.

Related Packages

Package	Description
org.apache.beam.sdk.extensions.sql.impl	Implementation classes of BeamSql.
org.apache.beam.sdk.extensions.sql.impl.transform.agg	Implementation of standard SQL aggregation functions, e.g.

Classes

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