Anton Kedin created BEAM-3634:
---------------------------------
Summary: [SQL] Refactor PTransforms
Key: BEAM-3634
URL: https://issues.apache.org/jira/browse/BEAM-3634
Project: Beam
Issue Type: Improvement
Components: dsl-sql
Reporter: Anton Kedin
BeamRelNode exposes PCollection<BeamRecord> buildBeamPipeline() which builds a
pipeline when parsing.
It feels like it should instead implement a PTransform<PCollection<BeamRecord>,
PCollection<BeamRecord>> which would receive a prepared PCollection, and apply
sub-expressions instead of manually invoking expression evaluation to get the
input.
And maybe consider building it lazily.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
