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

Class ZetaSQLPlannerImpl

java.lang.Object

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

All Implemented Interfaces:

java.lang.AutoCloseable, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.Planner

public class ZetaSQLPlannerImpl
extends java.lang.Object
implements org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.Planner

ZetaSQLPlannerImpl.

Constructor Summary

Constructors

Constructor and Description
ZetaSQLPlannerImpl(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.FrameworkConfig config)

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode	convert(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode sqlNode)
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelTraitSet	getEmptyTraitSet()
static com.google.zetasql.LanguageOptions	getLanguageOptions()
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataTypeFactory	getTypeFactory()
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode	parse(java.io.Reader reader)
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode	parse(java.lang.String s)
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelRoot	rel(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode sqlNode)
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelRoot	rel(java.lang.String sql, QueryPlanner.QueryParameters params)
void	reset()
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode	transform(int i, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelTraitSet relTraitSet, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode relNode)
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode	validate(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode sqlNode)
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.util.Pair<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode,org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType>	validateAndGetType(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode sqlNode)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZetaSQLPlannerImpl

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

Method Detail

parse

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode parse(java.lang.String s)
                                                                            throws org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.parser.SqlParseException

Specified by:

parse in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.Planner

Throws:

org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.parser.SqlParseException

parse

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode parse(java.io.Reader reader)
                                                                            throws org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.parser.SqlParseException

Specified by:

parse in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.Planner

Throws:

org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.parser.SqlParseException

validate

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode validate(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode sqlNode)
                                                                               throws org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.ValidationException

Specified by:

validate in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.Planner

Throws:

org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.ValidationException

validateAndGetType

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.util.Pair<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode,org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType> validateAndGetType(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode sqlNode)
                                                                                                                                                                                                                                             throws org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.ValidationException

Specified by:

validateAndGetType in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.Planner

Throws:

org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.ValidationException

rel

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelRoot rel(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode sqlNode)
                                                                          throws org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RelConversionException

Specified by:

rel in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.Planner

Throws:

org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RelConversionException

rel

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelRoot rel(java.lang.String sql,
                                                                                 QueryPlanner.QueryParameters params)

convert

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode convert(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode sqlNode)

Specified by:

convert in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.Planner

getTypeFactory

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataTypeFactory getTypeFactory()

Specified by:

getTypeFactory in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.Planner

transform

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode transform(int i,
                                                                                       org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelTraitSet relTraitSet,
                                                                                       org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode relNode)
                                                                                throws org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RelConversionException

Specified by:

transform in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.Planner

Throws:

org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RelConversionException

reset

public void reset()

Specified by:

reset in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.Planner

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.Planner

getEmptyTraitSet

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelTraitSet getEmptyTraitSet()

Specified by:

getEmptyTraitSet in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.Planner

getLanguageOptions

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