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
Filter	copy(RelTraitSet traitSet, RelNode input, RexNode condition)
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

BeamFilterRel

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

Method Detail

copy

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

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