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

Class QueryStatementConverter

java.lang.Object

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

public class QueryStatementConverter
extends java.lang.Object

Converts a resolved Zeta SQL query represented by a tree to corresponding Calcite representation.

Field Summary

Fields

Modifier and Type	Field and Description
protected ConversionContext	context Conversion context, contains things like FrameworkConfig, QueryTrait and other state used during conversion.

Method Summary

Modifier and Type	Method and Description
boolean	canConvert(T zetaNode) Whether this rule can handle the conversion of the specific node.
org.apache.calcite.rel.RelNode	convert(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedQueryStmt zetaNode, java.util.List<org.apache.calcite.rel.RelNode> inputs) Converts given Zeta SQL node to corresponding Calcite node.
static org.apache.calcite.rel.RelNode	convertRootQuery(ConversionContext context, com.google.zetasql.resolvedast.ResolvedNodes.ResolvedQueryStmt query)
protected org.apache.calcite.plan.RelOptCluster	getCluster()
protected org.apache.calcite.tools.FrameworkConfig	getConfig()
protected ExpressionConverter	getExpressionConverter()
java.util.List<com.google.zetasql.resolvedast.ResolvedNode>	getInputs(T zetaNode) Extract Zeta SQL resolved nodes that correspond to the inputs of the current node.
protected QueryTrait	getTrait()

Methods inherited from class java.lang.Object

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

Field Detail

context

protected ConversionContext context

Conversion context, contains things like FrameworkConfig, QueryTrait and other state used during conversion.

Method Detail

convertRootQuery

public static org.apache.calcite.rel.RelNode convertRootQuery(ConversionContext context,
                                                              com.google.zetasql.resolvedast.ResolvedNodes.ResolvedQueryStmt query)

convert

public org.apache.calcite.rel.RelNode convert(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedQueryStmt zetaNode,
                                              java.util.List<org.apache.calcite.rel.RelNode> inputs)

Converts given Zeta SQL node to corresponding Calcite node.

inputs are node inputs that have already been converter to Calcite versions. They correspond to the nodes in getInputs(ResolvedNode).

canConvert

public boolean canConvert(T zetaNode)

Whether this rule can handle the conversion of the specific node.

getInputs

public java.util.List<com.google.zetasql.resolvedast.ResolvedNode> getInputs(T zetaNode)

Extract Zeta SQL resolved nodes that correspond to the inputs of the current node.

getCluster

protected org.apache.calcite.plan.RelOptCluster getCluster()

getConfig

protected org.apache.calcite.tools.FrameworkConfig getConfig()

getExpressionConverter

protected ExpressionConverter getExpressionConverter()

getTrait

protected QueryTrait getTrait()