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 java.lang.Object

Utilities for BeamRelNode.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
BeamSqlRelUtils()

Method Summary

Modifier and Type	Method	Description
static java.lang.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 org.apache.beam.sdk.schemas.Schema	getErrorRowSchema(org.apache.beam.sdk.schemas.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 org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row>	toPCollection(org.apache.beam.sdk.Pipeline pipeline, BeamRelNode node)
static org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row>	toPCollection(org.apache.beam.sdk.Pipeline pipeline, BeamRelNode node, @Nullable org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row>,? extends org.apache.beam.sdk.values.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 org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row> toPCollection(org.apache.beam.sdk.Pipeline pipeline,
                                                                                                   BeamRelNode node)

toPCollection

public static org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row> toPCollection(org.apache.beam.sdk.Pipeline pipeline,
                                                                                                   BeamRelNode node,
                                                                                                   @Nullable org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row>,? extends org.apache.beam.sdk.values.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 org.apache.beam.sdk.schemas.Schema getErrorRowSchema(org.apache.beam.sdk.schemas.Schema upstreamSchema)

explainLazily

public static java.lang.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.