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 |
---|---|
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. |
public BeamFilterRel(RelOptCluster cluster, RelTraitSet traits, RelNode child, RexNode condition)
public Filter copy(RelTraitSet traitSet, RelNode input, RexNode condition)
public PTransform<PCollectionTuple,PCollection<Row>> toPTransform()
BeamRelNode
BeamRelNode
is a recursive structure, the BeamQueryPlanner
visits it with a
DFS(Depth-First-Search) algorithm.toPTransform
in interface BeamRelNode