[
https://issues.apache.org/jira/browse/SAMZA-915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403550#comment-15403550
]
Yi Pan (Data Infrastructure) commented on SAMZA-915:
----------------------------------------------------
Change this to target for implementation of Pipeline of operator DAGs.
> 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)
