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

Interface BeamRelNode

All Known Implementing Classes:

BeamAggregationRel, BeamFilterRel, BeamIntersectRel, BeamIOSinkRel, BeamIOSourceRel, BeamJoinRel, BeamMinusRel, BeamProjectRel, BeamSortRel, BeamUnionRel, BeamValuesRel

public interface BeamRelNode

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

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.

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.