Package 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 Object

Utilities for BeamRelNode.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ERROR
static final String	ROW

Constructor Summary

Constructors

Constructor	Description
BeamSqlRelUtils()

Method Summary

Modifier and Type	Method	Description
static Object	explainLazily(org.apache.beam.vendor.calcite.v1_40_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_40_0.org.apache.calcite.rel.RelNode input)
static Schema	getErrorRowSchema(Schema upstreamSchema)
static org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode	getInput(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode input)
static NodeStats	getNodeStats(org.apache.beam.vendor.calcite.v1_40_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 Details

ROW

public static final String ROW

See Also:

• Constant Field Values

ERROR

public static final String ERROR

See Also:

• Constant Field Values

Constructor Details

BeamSqlRelUtils

public BeamSqlRelUtils()

Method Details

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

getInput

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

getNodeStats

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

getErrorRowSchema

public static Schema getErrorRowSchema(Schema upstreamSchema)

explainLazily

public static Object explainLazily(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode node)

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