org.apache.beam.sdk.extensions.sql.zetasql

Class ZetaSQLQueryPlanner

java.lang.Object

org.apache.beam.sdk.extensions.sql.zetasql.ZetaSQLQueryPlanner

All Implemented Interfaces:

QueryPlanner

public class ZetaSQLQueryPlanner
extends java.lang.Object
implements QueryPlanner

ZetaSQLQueryPlanner.

Nested Class Summary

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

QueryPlanner.QueryParameters

Constructor Summary

Constructors

Constructor and Description
ZetaSQLQueryPlanner(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.FrameworkConfig config)
ZetaSQLQueryPlanner(JdbcConnection jdbcConnection, 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)
BeamRelNode	convertToBeamRel(java.lang.String sqlStatement, java.util.List<com.google.zetasql.Value> queryParams)
BeamRelNode	convertToBeamRel(java.lang.String sqlStatement, java.util.Map<java.lang.String,com.google.zetasql.Value> queryParams)
BeamRelNode	convertToBeamRel(java.lang.String sqlStatement, QueryPlanner.QueryParameters queryParameters) It parses and validate the input query, then convert into a BeamRelNode tree.
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RuleSet[]	getZetaSqlRuleSets()
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

ZetaSQLQueryPlanner

public ZetaSQLQueryPlanner(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.FrameworkConfig config)

ZetaSQLQueryPlanner

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

Method Detail

getZetaSqlRuleSets

public static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RuleSet[] getZetaSqlRuleSets()

convertToBeamRel

public BeamRelNode convertToBeamRel(java.lang.String sqlStatement)

convertToBeamRel

public BeamRelNode convertToBeamRel(java.lang.String sqlStatement,
                                    java.util.Map<java.lang.String,com.google.zetasql.Value> queryParams)
                             throws ParseException,
                                    SqlConversionException

Throws:

ParseException

SqlConversionException

convertToBeamRel

public BeamRelNode convertToBeamRel(java.lang.String sqlStatement,
                                    java.util.List<com.google.zetasql.Value> queryParams)
                             throws ParseException,
                                    SqlConversionException

Throws:

ParseException

SqlConversionException

convertToBeamRel

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

Description copied from interface: QueryPlanner

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

Specified by:

convertToBeamRel in interface QueryPlanner

Throws:

ParseException

SqlConversionException

parse

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

Description copied from interface: QueryPlanner

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

Specified by:

parse in interface QueryPlanner

Throws:

ParseException