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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
BeamRelNode	convertToBeamRel(String sqlStatement)
BeamRelNode	convertToBeamRel(String sqlStatement, List<com.google.zetasql.Value> queryParams)
BeamRelNode	convertToBeamRel(String sqlStatement, Map<String,com.google.zetasql.Value> queryParams)
BeamRelNode	convertToBeamRel(String sqlStatement, QueryPlanner.QueryParameters queryParameters)	It parses and validate the input query, then convert into a BeamRelNode tree.
String	getDefaultTimezone()
static com.google.zetasql.LanguageOptions	getLanguageOptions()
static Collection<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.RuleSet>	getZetaSqlRuleSets()
static Collection<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.RuleSet>	getZetaSqlRuleSets(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(String sqlStatement)	Parse input SQL query, and return a SqlNode as grammar tree.
void	setDefaultTimezone(String timezone)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_CALC

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

FACTORY

public static final QueryPlanner.Factory FACTORY

Constructor Details

ZetaSQLQueryPlanner

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

ZetaSQLQueryPlanner

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

Called by BeamSqlEnv.instantiatePlanner() reflectively.

Method Details

getZetaSqlRuleSets

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

getZetaSqlRuleSets

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

getDefaultTimezone

public String getDefaultTimezone()

setDefaultTimezone

public void setDefaultTimezone(String timezone)

getLanguageOptions

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

convertToBeamRel

public BeamRelNode convertToBeamRel(String sqlStatement)

convertToBeamRel

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

Throws:

ParseException

SqlConversionException

convertToBeamRel

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

Throws:

ParseException

SqlConversionException

convertToBeamRel

public BeamRelNode convertToBeamRel(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(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