Class QueryStatementConverter
java.lang.Object
org.apache.beam.sdk.extensions.sql.zetasql.translation.QueryStatementConverter
Converts a resolved Zeta SQL query represented by a tree to corresponding Calcite representation.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected ConversionContext
Conversion context, contains things like FrameworkConfig, QueryTrait and other state used during conversion. -
Method Summary
Modifier and TypeMethodDescriptionboolean
canConvert
(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedQueryStmt zetaNode) Whether this rule can handle the conversion of the specific node.org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode
convert
(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedQueryStmt zetaNode, List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode> inputs) Converts given Zeta SQL node to corresponding Calcite node.static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode
convertRootQuery
(ConversionContext context, com.google.zetasql.resolvedast.ResolvedNodes.ResolvedQueryStmt query) protected org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptCluster
protected org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.FrameworkConfig
protected ExpressionConverter
List
<com.google.zetasql.resolvedast.ResolvedNode> getInputs
(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedQueryStmt zetaNode) Extract Zeta SQL resolved nodes that correspond to the inputs of the current node.protected QueryTrait
getTrait()
-
Field Details
-
context
Conversion context, contains things like FrameworkConfig, QueryTrait and other state used during conversion.
-
-
Method Details
-
convertRootQuery
public static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode convertRootQuery(ConversionContext context, com.google.zetasql.resolvedast.ResolvedNodes.ResolvedQueryStmt query) -
convert
public org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode convert(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedQueryStmt zetaNode, List<org.apache.beam.vendor.calcite.v1_28_0.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 ingetInputs(ResolvedNode)
. -
canConvert
public boolean canConvert(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedQueryStmt zetaNode) Whether this rule can handle the conversion of the specific node. -
getInputs
public List<com.google.zetasql.resolvedast.ResolvedNode> getInputs(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedQueryStmt zetaNode) Extract Zeta SQL resolved nodes that correspond to the inputs of the current node. -
getCluster
protected org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptCluster getCluster() -
getConfig
protected org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.FrameworkConfig getConfig() -
getExpressionConverter
-
getTrait
-