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)
