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 java.util.Collection<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptRule>	DEFAULT_CALC
static QueryPlanner.Factory	FACTORY

Constructor Summary

Constructors

Constructor and Description
ZetaSQLQueryPlanner(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.FrameworkConfig config)
ZetaSQLQueryPlanner(JdbcConnection jdbcConnection, java.util.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 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_28_0.org.apache.calcite.tools.RuleSet>	getZetaSqlRuleSets()
static java.util.Collection<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.RuleSet>	getZetaSqlRuleSets(java.util.Collection<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptRule> calc)
org.apache.beam.vendor.calcite.v1_28_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

DEFAULT_CALC

public static final java.util.Collection<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptRule> DEFAULT_CALC

FACTORY

public static final QueryPlanner.Factory FACTORY

Constructor Detail

ZetaSQLQueryPlanner

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

ZetaSQLQueryPlanner

public ZetaSQLQueryPlanner(JdbcConnection jdbcConnection,
                           java.util.Collection<org.apache.beam.vendor.calcite.v1_28_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_28_0.org.apache.calcite.tools.RuleSet> getZetaSqlRuleSets()

getZetaSqlRuleSets

public static java.util.Collection<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.RuleSet> getZetaSqlRuleSets(java.util.Collection<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptRule> calc)

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_28_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