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

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.
BeamSqlFilterFn	`BeamSqlFilterFn` is the executor for a `BeamFilterRel` step.
BeamSqlOutputToConsoleFn	A test PTransform to display output in console.
BeamSqlProjectFn	`BeamSqlProjectFn` is the executor for a `BeamProjectRel` step.

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

PTransform used in a BeamSql pipeline.