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.

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

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.