[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer

2015-07-22 Thread ASF GitHub Bot (JIRA)

[ 
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

2015-07-22 Thread ASF GitHub Bot (JIRA)

[ 
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

2015-07-21 Thread ASF GitHub Bot (JIRA)

[ 
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

2015-07-13 Thread ASF GitHub Bot (JIRA)

[ 
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

2015-07-11 Thread ASF GitHub Bot (JIRA)

[ 
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

2015-07-03 Thread ASF GitHub Bot (JIRA)

[ 
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

2015-07-03 Thread ASF GitHub Bot (JIRA)

[ 
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

2015-07-03 Thread ASF GitHub Bot (JIRA)

[ 
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

2015-07-02 Thread ASF GitHub Bot (JIRA)

[ 
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

2015-07-01 Thread ASF GitHub Bot (JIRA)

[ 
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

2015-07-01 Thread ASF GitHub Bot (JIRA)

[ 
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

2015-07-01 Thread ASF GitHub Bot (JIRA)

[ 
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)