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

Class BeamIOSourceRel

java.lang.Object

TableScan

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

All Implemented Interfaces:

BeamRelNode

public class BeamIOSourceRel
extends TableScan
implements BeamRelNode

BeamRelNode to replace a TableScan node.

Constructor Summary

Constructors

Constructor and Description
BeamIOSourceRel(RelOptCluster cluster, RelTraitSet traitSet, RelOptTable table)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamIOSourceRel

public BeamIOSourceRel(RelOptCluster cluster,
                       RelTraitSet traitSet,
                       RelOptTable table)

Method Detail

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