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.

Constructor Summary

Constructors

Constructor and Description
ZetaSQLQueryPlanner(org.apache.calcite.tools.FrameworkConfig config)
ZetaSQLQueryPlanner(JdbcConnection jdbcConnection, org.apache.calcite.tools.RuleSet[] ruleSets)

Method Summary

Modifier and Type	Method and Description
BeamRelNode	convertToBeamRel(java.lang.String sqlStatement) It parses and validate the input query, then convert into a BeamRelNode tree.
BeamRelNode	convertToBeamRel(java.lang.String sqlStatement, java.util.Map<java.lang.String,com.google.zetasql.Value> queryParams)
org.apache.calcite.sql.SqlNode	parse(java.lang.String sqlStatement) Parse input SQL query, and return a SqlNode as grammar tree.
BeamRelNode	parseQuery(java.lang.String sql)
BeamRelNode	parseQuery(java.lang.String sql, java.util.Map<java.lang.String,com.google.zetasql.Value> queryParams)

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.calcite.tools.FrameworkConfig config)

ZetaSQLQueryPlanner

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

Method Detail

convertToBeamRel

public BeamRelNode convertToBeamRel(java.lang.String sqlStatement)
                             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.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

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

parseQuery

public BeamRelNode parseQuery(java.lang.String sql)
                       throws org.apache.calcite.tools.RelConversionException

Throws:

org.apache.calcite.tools.RelConversionException

parseQuery

public BeamRelNode parseQuery(java.lang.String sql,
                              java.util.Map<java.lang.String,com.google.zetasql.Value> queryParams)
                       throws org.apache.calcite.tools.RelConversionException

Throws:

org.apache.calcite.tools.RelConversionException