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.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ERROR
static java.lang.String	ROW

Constructor Summary

Constructors

Constructor and Description
BeamSqlRelUtils()

Method Summary

Modifier and Type	Method and Description
static java.lang.Object	explainLazily(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode node) A lazy explain via Object.toString() for logging purposes.
static BeamRelNode	getBeamRelInput(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode input)
static Schema	getErrorRowSchema(Schema upstreamSchema)
static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode	getInput(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode input)
static NodeStats	getNodeStats(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode input, BeamRelMetadataQuery mq)
static PCollection<Row>	toPCollection(Pipeline pipeline, BeamRelNode node)
static PCollection<Row>	toPCollection(Pipeline pipeline, BeamRelNode node, @Nullable PTransform<PCollection<Row>,? extends POutput> errorTransformer)

Methods inherited from class java.lang.Object

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

Field Detail

ROW

public static final java.lang.String ROW

See Also:

Constant Field Values

ERROR

public static final java.lang.String ERROR

See Also:

Constant Field Values

Constructor Detail

BeamSqlRelUtils

public BeamSqlRelUtils()

Method Detail

toPCollection

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

toPCollection

public static PCollection<Row> toPCollection(Pipeline pipeline,
                                             BeamRelNode node,
                                             @Nullable PTransform<PCollection<Row>,? extends POutput> errorTransformer)

getBeamRelInput

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

getInput

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

getNodeStats

public static NodeStats getNodeStats(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode input,
                                     BeamRelMetadataQuery mq)

getErrorRowSchema

public static Schema getErrorRowSchema(Schema upstreamSchema)

explainLazily

public static java.lang.Object explainLazily(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode node)

A lazy explain via Object.toString() for logging purposes.