You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@storm.apache.org by "Jungtaek Lim (JIRA)" <ji...@apache.org> on 2016/08/31 03:48:20 UTC

[jira] [Created] (STORM-2072) Add map, flatMap with different outputs (T->V) in Trident

Jungtaek Lim created STORM-2072:
-----------------------------------

             Summary: Add map, flatMap with different outputs (T->V) in Trident
                 Key: STORM-2072
                 URL: https://issues.apache.org/jira/browse/STORM-2072
             Project: Apache Storm
          Issue Type: Improvement
          Components: storm-core
            Reporter: Jungtaek Lim
            Assignee: Jungtaek Lim


In STORM-1505 we introduced map, flatMap, filter to Trident which are more familiar than what Trident originally had (users had to use each and project to do the similar thing).

Current version of map and flatMap assume next output fields are same to current output fields, in other words, supporting only T -> T conversion. But in many situations we need to have T -> V conversion.

This issue adds T -> V conversion (via method overloading) to both map and flatMap.



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