[
https://issues.apache.org/jira/browse/SAMZA-915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yi Pan (Data Infrastructure) resolved SAMZA-915.
------------------------------------------------
Resolution: Duplicate
Assignee: Yi Pan (Data Infrastructure)
Superseded by the design doc and implementation in SAMZA-914
> Design and implement operator programming APIs to support linear pipeline
> -------------------------------------------------------------------------
>
> Key: SAMZA-915
> URL: https://issues.apache.org/jira/browse/SAMZA-915
> Project: Samza
> Issue Type: Sub-task
> Reporter: Yi Pan (Data Infrastructure)
> Assignee: Yi Pan (Data Infrastructure)
>
> This would include the programming APIs that support the following linear
> pipeline:
> {code}
> sourceStream.filter(filter).map(mapper).flatMap(flatMapper).sink(sink);
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
