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.calcite.tools.Planner

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

ZetaSQLPlannerImpl.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.calcite.rel.RelNode	convert(org.apache.calcite.sql.SqlNode sqlNode)
org.apache.calcite.plan.RelTraitSet	getEmptyTraitSet()
org.apache.calcite.rel.type.RelDataTypeFactory	getTypeFactory()
org.apache.calcite.sql.SqlNode	parse(java.io.Reader reader)
org.apache.calcite.sql.SqlNode	parse(java.lang.String s)
org.apache.calcite.rel.RelRoot	rel(org.apache.calcite.sql.SqlNode sqlNode)
org.apache.calcite.rel.RelRoot	rel(java.lang.String sql, java.util.Map<java.lang.String,com.google.zetasql.Value> params)
void	reset()
org.apache.calcite.rel.RelNode	transform(int i, org.apache.calcite.plan.RelTraitSet relTraitSet, org.apache.calcite.rel.RelNode relNode)
org.apache.calcite.sql.SqlNode	validate(org.apache.calcite.sql.SqlNode sqlNode)
org.apache.calcite.util.Pair<org.apache.calcite.sql.SqlNode,org.apache.calcite.rel.type.RelDataType>	validateAndGetType(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.calcite.tools.FrameworkConfig config)

Method Detail

parse

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

Specified by:

parse in interface org.apache.calcite.tools.Planner

Throws:

org.apache.calcite.sql.parser.SqlParseException

parse

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

Specified by:

parse in interface org.apache.calcite.tools.Planner

Throws:

org.apache.calcite.sql.parser.SqlParseException

validate

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

Specified by:

validate in interface org.apache.calcite.tools.Planner

Throws:

org.apache.calcite.tools.ValidationException

validateAndGetType

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

Specified by:

validateAndGetType in interface org.apache.calcite.tools.Planner

Throws:

org.apache.calcite.tools.ValidationException

rel

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

Specified by:

rel in interface org.apache.calcite.tools.Planner

Throws:

org.apache.calcite.tools.RelConversionException

rel

public org.apache.calcite.rel.RelRoot rel(java.lang.String sql,
                                          java.util.Map<java.lang.String,com.google.zetasql.Value> params)

convert

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

Specified by:

convert in interface org.apache.calcite.tools.Planner

getTypeFactory

public org.apache.calcite.rel.type.RelDataTypeFactory getTypeFactory()

Specified by:

getTypeFactory in interface org.apache.calcite.tools.Planner

transform

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

Specified by:

transform in interface org.apache.calcite.tools.Planner

Throws:

org.apache.calcite.tools.RelConversionException

reset

public void reset()

Specified by:

reset in interface org.apache.calcite.tools.Planner

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface org.apache.calcite.tools.Planner

getEmptyTraitSet

public org.apache.calcite.plan.RelTraitSet getEmptyTraitSet()

Specified by:

getEmptyTraitSet in interface org.apache.calcite.tools.Planner