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 java.lang.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 and Description
static class	CalciteQueryPlanner.NonCumulativeCostImpl

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

QueryPlanner.QueryParameters

Constructor Summary

Constructors

Constructor and Description
CalciteQueryPlanner(JdbcConnection connection, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RuleSet[] ruleSets)

Method Summary

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

Constructor Detail

CalciteQueryPlanner

public CalciteQueryPlanner(JdbcConnection connection,
                           org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RuleSet[] ruleSets)

Method Detail

defaultConfig

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.FrameworkConfig defaultConfig(JdbcConnection connection,
                                                                                                     org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RuleSet[] ruleSets)

parse

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode parse(java.lang.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(java.lang.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