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

Class BeamSetOperatorsTransforms

java.lang.Object

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

public abstract class BeamSetOperatorsTransforms
extends Object

Collections of PTransform and DoFn used to perform Set operations.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BeamSetOperatorsTransforms.BeamSqlRow2KvFn	Transform a BeamSqlRow to a KV<BeamSqlRow, BeamSqlRow>.
static class	BeamSetOperatorsTransforms.SetOperatorFilteringDoFn	Filter function used for Set operators.

Constructor Summary

Constructors

Constructor	Description
BeamSetOperatorsTransforms()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BeamSetOperatorsTransforms

public BeamSetOperatorsTransforms()