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

Class BeamProjectRel

java.lang.Object

Project

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

All Implemented Interfaces:

BeamRelNode

public class BeamProjectRel
extends Project
implements BeamRelNode

BeamRelNode to replace a Project node.

Constructor Summary

Constructors

Constructor and Description
BeamProjectRel(RelOptCluster cluster, RelTraitSet traits, RelNode input, java.util.List<? extends RexNode> projects, RelDataType rowType) projects: RexLiteral, RexInputRef, RexCall.

Method Summary

Modifier and Type	Method and Description
Project	copy(RelTraitSet traitSet, RelNode input, java.util.List<RexNode> projects, RelDataType rowType)
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

BeamProjectRel

public BeamProjectRel(RelOptCluster cluster,
                      RelTraitSet traits,
                      RelNode input,
                      java.util.List<? extends RexNode> projects,
                      RelDataType rowType)

projects: RexLiteral, RexInputRef, RexCall.

Method Detail

copy

public Project copy(RelTraitSet traitSet,
                    RelNode input,
                    java.util.List<RexNode> projects,
                    RelDataType rowType)

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