[ https://issues.apache.org/jira/browse/BEAM-3634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Anton Kedin updated BEAM-3634: ------------------------------ Summary: [SQL] Refactor BeamRelNodes into PTransforms (was: [SQL] Refactor PTransforms) > [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 > 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)