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.calcite.rel.RelNode input)
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.calcite.rel.RelNode input)