Manu Zhang created GEARPUMP-111:
-----------------------------------
Summary: optimize Stream DSL broadcasting slave operations
Key: GEARPUMP-111
URL: https://issues.apache.org/jira/browse/GEARPUMP-111
Project: Apache Gearpump
Issue Type: Improvement
Components: streaming
Reporter: Manu Zhang
Priority: Minor
In Stream DSL, all broadcasting slave operations tailing a master operation
will be translated to individual tasks.
For example,
{code}
val stream = StreamApp.source(source, 1, "source")
stream.filter(fn, "filter A")
stream.filter(fn, "filter B")
stream.filter(fn, "filter C")
{code}
This will be translated to 1 SourceTask and 3 FilterTasks although it's
possible for them to be done in 1 Task.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
