[
https://issues.apache.org/jira/browse/BEAM-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009840#comment-16009840
]
ASF GitHub Bot commented on BEAM-2292:
--------------------------------------
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3138
[BEAM-2292] PCollection as a Table
add BeamPCollectionTable to create table from PCollection<BeamSQLRow>
Note that it changes the interface of `BaseBeamTable`, as a
`BeamPCollectionTable` doesn't start from `PBegin`, return
`PCollection<BeamSQLRow>` is more clear:
```
- public abstract PTransform<? super PBegin, PCollection<BeamSQLRow>>
buildIOReader();
+ public abstract PCollection<BeamSQLRow> buildIOReader(Pipeline pipeline);
```
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam BEAM-2292
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/beam/pull/3138.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3138
----
commit 148e0b30cf1a7e6be3ddb1fd75f4e4265090d708
Author: mingmxu <[email protected]>
Date: 2017-05-14T20:22:30Z
add BeamPCollectionTable to create table from PCollection<BeamSQLRow>
----
> PCollection as a Table
> ----------------------
>
> Key: BEAM-2292
> URL: https://issues.apache.org/jira/browse/BEAM-2292
> Project: Beam
> Issue Type: New Feature
> Components: dsl-sql
> Reporter: Xu Mingmin
> Assignee: Xu Mingmin
>
> To support method {{registerPCollectionAsTable}} in BeamSQL DSL.
> This feature makes it possible to break down a complex query into several
> sub-queries, and assemble it by developers.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
