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)
