Yi Pan (Data Infrastructure) created SAMZA-915: --------------------------------------------------
Summary: 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) 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)