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

Class BeamFilterRel

java.lang.Object

Filter

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

All Implemented Interfaces:

BeamRelNode

public class BeamFilterRel
extends Filter
implements BeamRelNode

BeamRelNode to replace a Filter node.

Constructor Summary

Constructors

Constructor and Description
BeamFilterRel(RelOptCluster cluster, RelTraitSet traits, RelNode child, RexNode condition)

Method Summary

Modifier and Type	Method and Description
PCollection<BeamRecord>	buildBeamPipeline(PCollectionTuple inputPCollections, BeamSqlEnv sqlEnv) A BeamRelNode is a recursive structure, the BeamQueryPlanner visits it with a DFS(Depth-First-Search) algorithm.
Filter	copy(RelTraitSet traitSet, RelNode input, RexNode condition)

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamFilterRel

public BeamFilterRel(RelOptCluster cluster,
                     RelTraitSet traits,
                     RelNode child,
                     RexNode condition)

Method Detail

copy

public Filter copy(RelTraitSet traitSet,
                   RelNode input,
                   RexNode condition)

buildBeamPipeline

public PCollection<BeamRecord> buildBeamPipeline(PCollectionTuple inputPCollections,
                                                 BeamSqlEnv sqlEnv)
                                          throws java.lang.Exception

Description copied from interface: BeamRelNode

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

Specified by:

buildBeamPipeline in interface BeamRelNode

Throws:

java.lang.Exception