[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636427#comment-14636427 ] ASF GitHub Bot commented on FLINK-2304: --- Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/878#issuecomment-123589583 Thanks I will merge it later today! :) Add named attribute access to Storm compatibility layer --- Key: FLINK-2304 URL: https://issues.apache.org/jira/browse/FLINK-2304 Project: Flink Issue Type: Improvement Components: flink-contrib Reporter: Matthias J. Sax Assignee: Matthias J. Sax Priority: Minor Currently, Bolts running in Flink can access fields only by index. Enabling named index access is possible for whole topologies and Tuple-type as well as POJO type inputs for embedded Bolts. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636760#comment-14636760 ] ASF GitHub Bot commented on FLINK-2304: --- Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/878 Add named attribute access to Storm compatibility layer --- Key: FLINK-2304 URL: https://issues.apache.org/jira/browse/FLINK-2304 Project: Flink Issue Type: Improvement Components: flink-contrib Reporter: Matthias J. Sax Assignee: Matthias J. Sax Priority: Minor Currently, Bolts running in Flink can access fields only by index. Enabling named index access is possible for whole topologies and Tuple-type as well as POJO type inputs for embedded Bolts. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635883#comment-14635883 ] ASF GitHub Bot commented on FLINK-2304: --- Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/878#issuecomment-123489145 Just rebased because #879 was merged today. This PR should be ready to get merged now. Add named attribute access to Storm compatibility layer --- Key: FLINK-2304 URL: https://issues.apache.org/jira/browse/FLINK-2304 Project: Flink Issue Type: Improvement Components: flink-contrib Reporter: Matthias J. Sax Assignee: Matthias J. Sax Priority: Minor Currently, Bolts running in Flink can access fields only by index. Enabling named index access is possible for whole topologies and Tuple-type as well as POJO type inputs for embedded Bolts. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14624992#comment-14624992 ] ASF GitHub Bot commented on FLINK-2304: --- Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/878#issuecomment-120999607 Update this PR (- added documentation). Should be ready to get merged. Add named attribute access to Storm compatibility layer --- Key: FLINK-2304 URL: https://issues.apache.org/jira/browse/FLINK-2304 Project: Flink Issue Type: Improvement Components: flink-contrib Reporter: Matthias J. Sax Assignee: Matthias J. Sax Priority: Minor Currently, Bolts running in Flink can access fields only by index. Enabling named index access is possible for whole topologies and Tuple-type as well as POJO type inputs for embedded Bolts. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14623371#comment-14623371 ] ASF GitHub Bot commented on FLINK-2304: --- Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/878#issuecomment-120612685 I merged #884 (it should get updated soon) so you can go ahead updating this so I can merge this. Add named attribute access to Storm compatibility layer --- Key: FLINK-2304 URL: https://issues.apache.org/jira/browse/FLINK-2304 Project: Flink Issue Type: Improvement Components: flink-contrib Reporter: Matthias J. Sax Assignee: Matthias J. Sax Priority: Minor Currently, Bolts running in Flink can access fields only by index. Enabling named index access is possible for whole topologies and Tuple-type as well as POJO type inputs for embedded Bolts. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14613199#comment-14613199 ] ASF GitHub Bot commented on FLINK-2304: --- Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/878#issuecomment-118356433 Ok. So this PR in put on hold and #884 can be merged right way. Add named attribute access to Storm compatibility layer --- Key: FLINK-2304 URL: https://issues.apache.org/jira/browse/FLINK-2304 Project: Flink Issue Type: Improvement Components: flink-contrib Reporter: Matthias J. Sax Assignee: Matthias J. Sax Priority: Minor Currently, Bolts running in Flink can access fields only by index. Enabling named index access is possible for whole topologies and Tuple-type as well as POJO type inputs for embedded Bolts. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14613057#comment-14613057 ] ASF GitHub Bot commented on FLINK-2304: --- Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/878#issuecomment-118291459 And it is also related to #879 which we should probably wait before merging these. It is probably a change of 2-3 lines here but it might stall the other PR long if we are merging small changes right before that one. Add named attribute access to Storm compatibility layer --- Key: FLINK-2304 URL: https://issues.apache.org/jira/browse/FLINK-2304 Project: Flink Issue Type: Improvement Components: flink-contrib Reporter: Matthias J. Sax Assignee: Matthias J. Sax Priority: Minor Currently, Bolts running in Flink can access fields only by index. Enabling named index access is possible for whole topologies and Tuple-type as well as POJO type inputs for embedded Bolts. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14613050#comment-14613050 ] ASF GitHub Bot commented on FLINK-2304: --- Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/878#issuecomment-118286784 FYI: this PR is related to #884 - if #884 is merged before, this PR needs an update. Add named attribute access to Storm compatibility layer --- Key: FLINK-2304 URL: https://issues.apache.org/jira/browse/FLINK-2304 Project: Flink Issue Type: Improvement Components: flink-contrib Reporter: Matthias J. Sax Assignee: Matthias J. Sax Priority: Minor Currently, Bolts running in Flink can access fields only by index. Enabling named index access is possible for whole topologies and Tuple-type as well as POJO type inputs for embedded Bolts. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14611736#comment-14611736 ] ASF GitHub Bot commented on FLINK-2304: --- Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/878#issuecomment-117986690 Looks good to me :+1: Add named attribute access to Storm compatibility layer --- Key: FLINK-2304 URL: https://issues.apache.org/jira/browse/FLINK-2304 Project: Flink Issue Type: Improvement Components: flink-contrib Reporter: Matthias J. Sax Assignee: Matthias J. Sax Priority: Minor Currently, Bolts running in Flink can access fields only by index. Enabling named index access is possible for whole topologies and Tuple-type as well as POJO type inputs for embedded Bolts. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14610068#comment-14610068 ] ASF GitHub Bot commented on FLINK-2304: --- GitHub user mjsax opened a pull request: https://github.com/apache/flink/pull/878 [FLINK-2304] Add named attribute access to Storm compatibility layer - extended FlinkTuple to enable named attribute access - extended BoltWrapper for user defined input schema - extended FlinkTopologyBuilder to handle declared output schemas - adapted JUnit tests - added new examples and ITCases - updated READMEs You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/flink flink-2304-storm-namedAttributes Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/878.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 #878 commit cb0f5df95667aee7a3a08a92226cefb4f31a2de3 Author: mjsax mj...@informatik.hu-berlin.de Date: 2015-06-29T15:50:07Z [FLINK-2304] Add named attribute access to Storm compatibility layer - extended FlinkTuple to enable named attribute access - extended BoltWrapper for user defined input schema - extended FlinkTopologyBuilder to handle declared output schemas - adapted JUnit tests - added new examples and ITCases - updated READMEs Add named attribute access to Storm compatibility layer --- Key: FLINK-2304 URL: https://issues.apache.org/jira/browse/FLINK-2304 Project: Flink Issue Type: Improvement Components: flink-contrib Reporter: Matthias J. Sax Assignee: Matthias J. Sax Priority: Minor Currently, Bolts running in Flink can access fields only by index. Enabling named index access is possible for whole topologies and Tuple-type as well as POJO type inputs for embedded Bolts. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14610058#comment-14610058 ] ASF GitHub Bot commented on FLINK-2304: --- Github user mjsax closed the pull request at: https://github.com/apache/flink/pull/875 Add named attribute access to Storm compatibility layer --- Key: FLINK-2304 URL: https://issues.apache.org/jira/browse/FLINK-2304 Project: Flink Issue Type: Improvement Components: flink-contrib Reporter: Matthias J. Sax Assignee: Matthias J. Sax Priority: Minor Currently, Bolts running in Flink can access fields only by index. Enabling named index access is possible for whole topologies and Tuple-type as well as POJO type inputs for embedded Bolts. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer
[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14610057#comment-14610057 ] ASF GitHub Bot commented on FLINK-2304: --- Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/875#issuecomment-117649187 Close and re-open in new branch to link to JIRA. Add named attribute access to Storm compatibility layer --- Key: FLINK-2304 URL: https://issues.apache.org/jira/browse/FLINK-2304 Project: Flink Issue Type: Improvement Components: flink-contrib Reporter: Matthias J. Sax Assignee: Matthias J. Sax Priority: Minor Currently, Bolts running in Flink can access fields only by index. Enabling named index access is possible for whole topologies and Tuple-type as well as POJO type inputs for embedded Bolts. -- This message was sent by Atlassian JIRA (v6.3.4#6332)