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 java.lang.Object

Collections of PTransform and DoFn used to perform Set operations.

Nested Class Summary

Nested Classes

Modifier and Type	Class and 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 and Description
BeamSetOperatorsTransforms()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamSetOperatorsTransforms

public BeamSetOperatorsTransforms()