[SAMZA-1073] Design top-level fluent APIs operators that are capable to be deployed in multi-stage jobs

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.13.0
• Assignee: Yi Pan
• Reporter: Yi Pan
• Created: 23/Dec/16 22:56
• Updated: 16/Feb/17 23:06
• Resolved: 16/Feb/17 23:06

Description

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.

Issue Links

• links to: GitHub Pull Request #51
• links to: GitHub Pull Request #55