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.Factory, QueryPlanner.QueryParameters

Field Summary

Fields

Modifier and Type	Field and Description
static QueryPlanner.Factory	FACTORY

Constructor Summary

Constructors

Constructor and Description
ZetaSQLQueryPlanner(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.FrameworkConfig config)
ZetaSQLQueryPlanner(JdbcConnection jdbcConnection, java.util.Collection<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RuleSet> ruleSets) Called by BeamSqlEnv.instantiatePlanner() reflectively.

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.
java.lang.String	getDefaultTimezone()
static com.google.zetasql.LanguageOptions	getLanguageOptions()
static java.util.Collection<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.
void	setDefaultTimezone(java.lang.String timezone)

Methods inherited from class java.lang.Object

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

Field Detail

FACTORY

public static final QueryPlanner.Factory FACTORY

Constructor Detail

ZetaSQLQueryPlanner

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

ZetaSQLQueryPlanner

public ZetaSQLQueryPlanner(JdbcConnection jdbcConnection,
                           java.util.Collection<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RuleSet> ruleSets)

Called by BeamSqlEnv.instantiatePlanner() reflectively.

Method Detail

getZetaSqlRuleSets

public static java.util.Collection<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RuleSet> getZetaSqlRuleSets()

getDefaultTimezone

public java.lang.String getDefaultTimezone()

setDefaultTimezone

public void setDefaultTimezone(java.lang.String timezone)

getLanguageOptions

public static com.google.zetasql.LanguageOptions getLanguageOptions()

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