[
https://issues.apache.org/jira/browse/BEAM-3634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kenneth Knowles reassigned BEAM-3634:
-------------------------------------
Assignee: Andrew Pilloud (was: 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: Andrew Pilloud
> Priority: Major
> Time Spent: 2h 20m
> Remaining Estimate: 0h
>
> 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)