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

Interface BeamRelNode

All Superinterfaces:

java.lang.Cloneable, org.apache.calcite.rel.RelNode, org.apache.calcite.plan.RelOptNode

All Known Implementing Classes:

BeamAggregationRel, BeamCalcRel, BeamIntersectRel, BeamIOSinkRel, BeamIOSourceRel, BeamJoinRel, BeamMinusRel, BeamSortRel, BeamUncollectRel, BeamUnionRel, BeamUnnestRel, BeamValuesRel

public interface BeamRelNode
extends org.apache.calcite.rel.RelNode

A RelNode that can also give a PTransform that implements the expression.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.rel.RelNode

org.apache.calcite.rel.RelNode.Context

Method Summary

Modifier and Type	Method and Description
PTransform<PCollectionList<Row>,PCollection<Row>>	buildPTransform()
default java.util.List<org.apache.calcite.rel.RelNode>	getPCollectionInputs()
default java.util.Map<java.lang.String,java.lang.String>	getPipelineOptions() Perform a DFS(Depth-First-Search) to find the PipelineOptions config.
default PCollection.IsBounded	isBounded() Whether the collection of rows represented by this relational expression is bounded (known to be finite) or unbounded (may or may not be finite).

Methods inherited from interface org.apache.calcite.rel.RelNode

accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, computeSelfCost, copy, estimateRowCount, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput

Methods inherited from interface org.apache.calcite.plan.RelOptNode

getCluster, getDescription, getDigest, getId, getTraitSet

Method Detail

isBounded

default PCollection.IsBounded isBounded()

Whether the collection of rows represented by this relational expression is bounded (known to be finite) or unbounded (may or may not be finite).

Returns:

bounded if and only if all PCollection inputs are bounded

getPCollectionInputs

default java.util.List<org.apache.calcite.rel.RelNode> getPCollectionInputs()

buildPTransform

PTransform<PCollectionList<Row>,PCollection<Row>> buildPTransform()

getPipelineOptions

default java.util.Map<java.lang.String,java.lang.String> getPipelineOptions()

Perform a DFS(Depth-First-Search) to find the PipelineOptions config.