public class BeamFilterRel extends Filter implements BeamRelNode
Filter
node.Constructor and Description |
---|
BeamFilterRel(RelOptCluster cluster,
RelTraitSet traits,
RelNode child,
RexNode condition) |
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) |
public BeamFilterRel(RelOptCluster cluster, RelTraitSet traits, RelNode child, RexNode condition)
public Filter copy(RelTraitSet traitSet, RelNode input, RexNode condition)
public PCollection<BeamRecord> buildBeamPipeline(PCollectionTuple inputPCollections, BeamSqlEnv sqlEnv) throws java.lang.Exception
BeamRelNode
BeamRelNode
is a recursive structure, the
BeamQueryPlanner
visits it with a DFS(Depth-First-Search)
algorithm.buildBeamPipeline
in interface BeamRelNode
java.lang.Exception