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 new method buildBeamPipeline(PCollectionTuple, BeamSqlEnv) is added.

Method Summary

Modifier and Type	Method and Description
PCollection<BeamRecord>	buildBeamPipeline(PCollectionTuple inputPCollections, BeamSqlEnv sqlEnv) A BeamRelNode is a recursive structure, the BeamQueryPlanner visits it with a DFS(Depth-First-Search) algorithm.

Method Detail

buildBeamPipeline

PCollection<BeamRecord> buildBeamPipeline(PCollectionTuple inputPCollections,
                                          BeamSqlEnv sqlEnv)
                                   throws java.lang.Exception

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

Throws:

java.lang.Exception