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

Class CalciteQueryPlanner

java.lang.Object

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

All Implemented Interfaces:

QueryPlanner

public class CalciteQueryPlanner
extends Object
implements QueryPlanner

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CalciteQueryPlanner.NonCumulativeCostImpl

Nested classes/interfaces inherited from interface org.apache.beam.sdk.extensions.sql.impl.QueryPlanner

QueryPlanner.Factory, QueryPlanner.QueryParameters

Field Summary

Fields

Modifier and Type	Field	Description
static final QueryPlanner.Factory	FACTORY

Constructor Summary

Constructors

Constructor	Description
CalciteQueryPlanner(JdbcConnection connection, Collection<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.RuleSet> ruleSets)	Called by BeamSqlEnv.instantiatePlanner() reflectively.

Method Summary

Modifier and Type	Method	Description
BeamRelNode	convertToBeamRel(String sqlStatement, QueryPlanner.QueryParameters queryParameters)	It parses and validate the input query, then convert into a BeamRelNode tree.
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.FrameworkConfig	defaultConfig(JdbcConnection connection, Collection<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.RuleSet> ruleSets)
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlNode	parse(String sqlStatement)	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 Details

FACTORY

public static final QueryPlanner.Factory FACTORY

Constructor Details

CalciteQueryPlanner

public CalciteQueryPlanner(JdbcConnection connection,
 Collection<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.RuleSet> ruleSets)

Called by BeamSqlEnv.instantiatePlanner() reflectively.

Method Details

defaultConfig

public org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.FrameworkConfig defaultConfig(JdbcConnection connection,
 Collection<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.RuleSet> ruleSets)

parse

public org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlNode parse(String sqlStatement)
                                                                            throws ParseException

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

Specified by:

parse in interface QueryPlanner

Throws:

ParseException

convertToBeamRel

public BeamRelNode convertToBeamRel(String sqlStatement,
 QueryPlanner.QueryParameters queryParameters)
                             throws ParseException,
SqlConversionException

It parses and validate the input query, then convert into a BeamRelNode tree. Note that query parameters are not yet supported.

Specified by:

convertToBeamRel in interface QueryPlanner

Throws:

ParseException

SqlConversionException