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(BeamSqlEnv sqlEnv, RelOptCluster cluster, RelTraitSet traitSet, RelOptTable table)

Method Summary

Modifier and Type	Method and Description
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

BeamIOSourceRel

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

Method Detail

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