[
https://issues.apache.org/jira/browse/SAMZA-915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15597146#comment-15597146
]
Yi Pan (Data Infrastructure) commented on SAMZA-915:
----------------------------------------------------
merged and submitted. Thank you all for the review!
-Yi
> 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)
> Attachments: rb47994.patch
>
>
> 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)
