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, BeamFilterRel, BeamIntersectRel, BeamIOSinkRel, BeamIOSourceRel, BeamJoinRel, BeamMinusRel, BeamProjectRel, 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<PCollectionTuple,PCollection<Row>>	toPTransform() A BeamRelNode is a recursive structure, the BeamQueryPlanner visits it with a DFS(Depth-First-Search) algorithm.

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

toPTransform

PTransform<PCollectionTuple,PCollection<Row>> toPTransform()

A BeamRelNode is a recursive structure, the BeamQueryPlanner visits it with a DFS(Depth-First-Search) algorithm.