[jira] [Commented] (STORM-1505) Add map, flatMap and filter operations in trident api

["ASF GitHub Bot (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/STORM-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15125976#comment-15125976 ] 

ASF GitHub Bot commented on STORM-1505:
---------------------------------------

Github user arunmahadevan commented on the pull request:

    https://github.com/apache/storm/pull/1050#issuecomment-177868343
  
    @ptgoetz updated `filter` api to use `each` as per your suggestion. Since I wanted to see the tuples flowing through in the example topology to make sure the apis are working as expected, I also added a `peek` api similar to the one available in java8 streams. 
    
    I created subtask for the 1.0 release jira for updating api docs. https://issues.apache.org/jira/browse/STORM-1513. Once the code changes are reviewed, I will update the docs.


> Add map, flatMap and filter operations in trident api
> -----------------------------------------------------
>
>                 Key: STORM-1505
>                 URL: https://issues.apache.org/jira/browse/STORM-1505
>             Project: Apache Storm
>          Issue Type: Improvement
>            Reporter: Arun Mahadevan
>            Assignee: Arun Mahadevan
>
> map and flatMap are common stream operations. 
> Right now in trident this has to be implemented via each() which also sends the input field values in addition to the mapped field values, so the map and flatmap should make things slightly more efficient and easy.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)