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/10 22:15:04 UTC

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

     [ https://issues.apache.org/jira/browse/SAMZA-1123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Xinyu Liu resolved SAMZA-1123.
------------------------------
    Resolution: Fixed

> 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)