org.apache.beam.sdk.extensions.sql.impl.rel

Class BeamSqlRelUtils

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.rel.BeamSqlRelUtils

public class BeamSqlRelUtils
extends java.lang.Object

Utilities for BeamRelNode.

Constructor Summary

Constructors

Constructor and Description
BeamSqlRelUtils()

Method Summary

Modifier and Type	Method and Description
static BeamRelNode	getBeamRelInput(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode input)
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode	getInput(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode input)
static NodeStats	getNodeStats(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode input, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.metadata.RelMetadataQuery mq)
static PCollection<Row>	toPCollection(Pipeline pipeline, BeamRelNode node)

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamSqlRelUtils

public BeamSqlRelUtils()

Method Detail

toPCollection

public static PCollection<Row> toPCollection(Pipeline pipeline,
                                             BeamRelNode node)

getBeamRelInput

public static BeamRelNode getBeamRelInput(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode input)

getInput

public static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode getInput(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode input)

getNodeStats

public static NodeStats getNodeStats(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode input,
                                     org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.metadata.RelMetadataQuery mq)