[GitHub] simingweng opened a new issue #3016: Support branching in Streamlet API

[GitBox <gi...@apache.org>]

simingweng opened a new issue #3016: Support branching in Streamlet API
URL: https://github.com/apache/incubator-heron/issues/3016
 
 
   Currently, Streamlet API lacks an operator to allow developer to define multiple output streams that can potentially carries data of different user types.
   
   The equivalent can be achieved by using the Spout/Bolt API, more specifically
   `SpoutOutputCollector.emit(java.lang.String streamId, java.util.List<java.lang.Object> tuple, java.lang.Object messageId)`
   or
   `OutputCollector.emit(java.lang.String streamId, Tuple anchor, java.util.List<java.lang.Object> tuple)`
   together with
   `OutputFieldsDeclarer.declareStream(java.lang.String streamId, Fields fields)`
   to emit different data on different streams.
   
   This would be particularly helpful when developer wants to route different types of data to separate downstream operators, each of which is written in a way that it only understands and handles one specific type of data. Basically, the operator enables the use scenario of "one distributor spout/bolt" -> "multiple processing bolts".
   
   The Stream API in Apache Storm 2.0.0-SNAPSHOT has such a [branch operator](http://storm.apache.org/releases/2.0.0-SNAPSHOT/Stream-API.html#branching) coming.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services