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

Posted to commits@samza.apache.org by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/03/07 18:22:38 UTC

[jira] [Created] (SAMZA-1123) Create intermediate stream in partitionBy() operator

Xinyu Liu created SAMZA-1123:
--------------------------------

             Summary: Create intermediate stream in partitionBy() operator
                 Key: SAMZA-1123
                 URL: https://issues.apache.org/jira/browse/SAMZA-1123
             Project: Samza
          Issue Type: New Feature
            Reporter: Xinyu Liu
            Assignee: Xinyu Liu


For partitionBy() operator, Samza generates an intermediate stream with id based on operator name and id, and system based on config. The intermediate streams will be materialized later by different execution environments. For example, if the intermediate stream is a Kafka stream, the topic will be created before the application starts.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)