[
https://issues.apache.org/jira/browse/FLINK-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14364465#comment-14364465
]
ASF GitHub Bot commented on FLINK-1641:
---------------------------------------
GitHub user ggevay opened a pull request:
https://github.com/apache/flink/pull/489
[FLINK-1641] Make projection operator chainable.
I tested this by adding a dummy project to the WordCount example, by adding
.project(0, 1).types(String.class, Integer.class)
to line 70.
Without the chaining modification, the log looks like this:
Deploying Grouped Aggregation (4/4) (attempt #0) to localhost
Deploying Projection -> Stream Sink (4/4) (attempt #0) to localhost
And with the modification, it looks like this:
Deploying Grouped Aggregation -> Projection -> Stream Sink (4/4) (attempt
#0) to localhost
If I read this correctly, then it means that it was chained as expected.
Should I also create an automated test for this?
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ggevay/flink master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/489.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 #489
----
commit 933315130876ab986d6d0ffde2f7c7d400c9d34e
Author: Gabor Gevay <[email protected]>
Date: 2015-03-17T02:02:35Z
[FLINK-1641] Make projection operator chainable.
----
> Make projection operator chainable
> ----------------------------------
>
> Key: FLINK-1641
> URL: https://issues.apache.org/jira/browse/FLINK-1641
> Project: Flink
> Issue Type: Improvement
> Components: Streaming
> Reporter: Gyula Fora
> Assignee: Gabor Gevay
>
> The ProjectInvokable currently doesn't extend the ChainableInvokable class.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
