[ 
https://issues.apache.org/jira/browse/BEAM-3634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Anton Kedin reassigned BEAM-3634:
---------------------------------

    Assignee: Kenneth Knowles

> [SQL] Refactor BeamRelNodes into PTransforms
> --------------------------------------------
>
>                 Key: BEAM-3634
>                 URL: https://issues.apache.org/jira/browse/BEAM-3634
>             Project: Beam
>          Issue Type: Improvement
>          Components: dsl-sql
>            Reporter: Anton Kedin
>            Assignee: Kenneth Knowles
>            Priority: Major
>
> 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)

Reply via email to