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

Class BeamQueryPlanner

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.planner.BeamQueryPlanner

public class BeamQueryPlanner
extends java.lang.Object

The core component to handle through a SQL statement, from explain execution plan, to generate a Beam pipeline.

Field Summary

Fields

Modifier and Type	Field and Description
protected Planner	planner
static JavaTypeFactory	TYPE_FACTORY

Constructor Summary

Constructors

Constructor and Description
BeamQueryPlanner(SchemaPlus schema)

Method Summary

Modifier and Type	Method and Description
PCollection<BeamRecord>	compileBeamPipeline(java.lang.String sqlStatement, Pipeline basePipeline, BeamSqlEnv sqlEnv) compileBeamPipeline translate a SQL statement to executed as Beam data flow, which is linked with the given pipeline.
BeamRelNode	convertToBeamRel(java.lang.String sqlStatement) It parses and validate the input query, then convert into a BeamRelNode tree.
Planner	getPlanner()
java.util.Map<java.lang.String,BeamSqlTable>	getSourceTables()
SqlNode	parseQuery(java.lang.String sqlQuery) Parse input SQL query, and return a SqlNode as grammar tree.

Methods inherited from class java.lang.Object

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

Field Detail

planner

protected final Planner planner

TYPE_FACTORY

public static final JavaTypeFactory TYPE_FACTORY

Constructor Detail

BeamQueryPlanner

public BeamQueryPlanner(SchemaPlus schema)

Method Detail

parseQuery

public SqlNode parseQuery(java.lang.String sqlQuery)
                   throws SqlParseException

Parse input SQL query, and return a SqlNode as grammar tree.

Throws:

SqlParseException

compileBeamPipeline

public PCollection<BeamRecord> compileBeamPipeline(java.lang.String sqlStatement,
                                                   Pipeline basePipeline,
                                                   BeamSqlEnv sqlEnv)
                                            throws java.lang.Exception

compileBeamPipeline translate a SQL statement to executed as Beam data flow, which is linked with the given pipeline. The final output stream is returned as PCollection so more operations can be applied.

Throws:

java.lang.Exception

convertToBeamRel

public BeamRelNode convertToBeamRel(java.lang.String sqlStatement)
                             throws ValidationException,
                                    RelConversionException,
                                    SqlParseException

It parses and validate the input query, then convert into a BeamRelNode tree.

Throws:

ValidationException

RelConversionException

SqlParseException

getSourceTables

public java.util.Map<java.lang.String,BeamSqlTable> getSourceTables()

getPlanner

public Planner getPlanner()