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

Class ArrayScanColumnRefToUncollect

java.lang.Object

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

public class ArrayScanColumnRefToUncollect
extends java.lang.Object

Converts array scan that represents a reference to array column literal to uncollect.

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(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedArrayScan zetaNode) Whether this rule can handle the conversion of the specific node.
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode	convert(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedArrayScan zetaNode, java.util.List<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode> inputs) Converts given Zeta SQL node to corresponding Calcite node.
protected org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptCluster	getCluster()
protected org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.FrameworkConfig	getConfig()
protected ExpressionConverter	getExpressionConverter()
java.util.List<com.google.zetasql.resolvedast.ResolvedNode>	getInputs(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedArrayScan 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

canConvert

public boolean canConvert(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedArrayScan zetaNode)

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

getInputs

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

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

convert

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode convert(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedArrayScan zetaNode,
                                                                                     java.util.List<org.apache.beam.vendor.calcite.v1_20_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 in getInputs(ResolvedNode).

getCluster

protected org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptCluster getCluster()

getConfig

protected org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.FrameworkConfig getConfig()

getExpressionConverter

protected ExpressionConverter getExpressionConverter()

getTrait

protected QueryTrait getTrait()