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

PTransform used in a BeamSql pipeline.

See: Description

Class Summary

Class	Description
BeamAggregationTransforms	Collections of PTransform and DoFn used to perform GROUP-BY operation.
BeamAggregationTransforms.AggregationAccumulator	A class to holder varied accumulator objects.
BeamAggregationTransforms.AggregationAccumulatorCoder	Coder for BeamAggregationTransforms.AggregationAccumulator.
BeamAggregationTransforms.AggregationAdaptor	An adaptor class to invoke Calcite UDAF instances in Beam CombineFn.
BeamAggregationTransforms.AggregationGroupByKeyFn	extract group-by fields.
BeamAggregationTransforms.MergeAggregationRecord	Merge KV to single record.
BeamAggregationTransforms.WindowTimestampFn	Assign event timestamp.
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.