gearpump-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Manu Zhang (JIRA)" <j...@apache.org>
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
                 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)

Mime
View raw message