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

Class BeamValuesRel

java.lang.Object

Values

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

All Implemented Interfaces:

BeamRelNode

public class BeamValuesRel
extends Values
implements BeamRelNode

BeamRelNode to replace a Values node.

BeamValuesRel will be used in the following SQLs:

• insert into t (name, desc) values ('hello', 'world')
• select 1, '1', LOCALTIME

Constructor Summary

Constructors

Constructor and Description
BeamValuesRel(RelOptCluster cluster, RelDataType rowType, ImmutableList<ImmutableList<RexLiteral>> tuples, RelTraitSet traits)

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

BeamValuesRel

public BeamValuesRel(RelOptCluster cluster,
                     RelDataType rowType,
                     ImmutableList<ImmutableList<RexLiteral>> tuples,
                     RelTraitSet traits)

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