[ https://issues.apache.org/jira/browse/BEAM-2234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Xu Mingmin updated BEAM-2234: ----------------------------- Description: Change the return of {{buildBeamPipeline}} to {{PCollection<BeamSQLRow>}}, this helps to: 1). donot need to manage the upstream-downstream as execution tree already have it; 2). easy for unit test with {{PAssert}}; was:To enable unit test with standard {{TestPipeline}} > expose PCollection of each RelNode > ---------------------------------- > > Key: BEAM-2234 > URL: https://issues.apache.org/jira/browse/BEAM-2234 > Project: Beam > Issue Type: Task > Components: dsl-sql > Reporter: Xu Mingmin > Assignee: Xu Mingmin > > Change the return of {{buildBeamPipeline}} to {{PCollection<BeamSQLRow>}}, > this helps to: > 1). donot need to manage the upstream-downstream as execution tree already > have it; > 2). easy for unit test with {{PAssert}}; -- This message was sent by Atlassian JIRA (v6.3.15#6346)