[ https://issues.apache.org/jira/browse/STORM-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jungtaek Lim resolved STORM-2072. --------------------------------- Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 Merged into master and 1.x branch. > 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 > Fix For: 2.0.0, 1.1.0 > > Time Spent: 1.5h > Remaining Estimate: 0h > > 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)