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

Class BeamIntersectRel

java.lang.Object

Intersect

org.apache.beam.sdk.extensions.sql.impl.rel.BeamIntersectRel

All Implemented Interfaces:

BeamRelNode

public class BeamIntersectRel
extends Intersect
implements BeamRelNode

BeamRelNode to replace a Intersect node.

This is used to combine two SELECT statements, but returns rows only from the first SELECT statement that are identical to a row in the second SELECT statement.

Constructor Summary

Constructors

Constructor and Description
BeamIntersectRel(RelOptCluster cluster, RelTraitSet traits, java.util.List<RelNode> inputs, boolean all)

Method Summary

Modifier and Type	Method and Description
SetOp	copy(RelTraitSet traitSet, java.util.List<RelNode> inputs, boolean all)
PTransform<PCollectionTuple,PCollection<Row>>	toPTransform() A BeamRelNode is a recursive structure, the BeamQueryPlanner visits it with a DFS(Depth-First-Search) algorithm.

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamIntersectRel

public BeamIntersectRel(RelOptCluster cluster,
                        RelTraitSet traits,
                        java.util.List<RelNode> inputs,
                        boolean all)

Method Detail

copy

public SetOp copy(RelTraitSet traitSet,
                  java.util.List<RelNode> inputs,
                  boolean all)

toPTransform

public PTransform<PCollectionTuple,PCollection<Row>> toPTransform()

Description copied from interface: BeamRelNode

A BeamRelNode is a recursive structure, the BeamQueryPlanner visits it with a DFS(Depth-First-Search) algorithm.

Specified by:

toPTransform in interface BeamRelNode