You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2016/12/23 22:56:58 UTC

[jira] [Created] (SAMZA-1073) Adding through and StreamSpec to the fluent APIs operators

Yi Pan (Data Infrastructure) created SAMZA-1073:
---------------------------------------------------

             Summary: Adding through and StreamSpec to the fluent APIs operators
                 Key: SAMZA-1073
                 URL: https://issues.apache.org/jira/browse/SAMZA-1073
             Project: Samza
          Issue Type: Sub-task
            Reporter: Yi Pan (Data Infrastructure)


It would be nice to allow users to stay at logic level when using fluent API's operators, w/o concerning about physical partitions of the stream and potential grouping of operators into multiple / single Samza jobs (SAMZA-1041).

Hence, the fluent API needs to be able to express the physical topics as boundaries between stages in the single logic DAG.

Besides, users should be able to use fluent API to describe a logic expression at top level, not within a job or within a task.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)