gearpump-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Manu Zhang (JIRA)" <>
Subject [jira] [Created] (GEARPUMP-111) optimize Stream DSL broadcasting slave operations
Date Thu, 28 Apr 2016 03:54:12 GMT
Manu Zhang created GEARPUMP-111:

             Summary: optimize Stream DSL broadcasting slave operations
                 Key: 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, 

val stream = StreamApp.source(source, 1, "source")
stream.filter(fn, "filter A")
stream.filter(fn, "filter B")
stream.filter(fn, "filter C")

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

View raw message