Yi Pan (Data Infrastructure) created SAMZA-916:
--------------------------------------------------
Summary: Design and implement operator programing APIs to support
split and join
Key: SAMZA-916
URL: https://issues.apache.org/jira/browse/SAMZA-916
Project: Samza
Issue Type: Sub-task
Reporter: Yi Pan (Data Infrastructure)
This is to implement programming APIs to support non-linear DAG of operators.
The key operators to support is to support split and join operations.
Some code example would be:
{code}
commonSource = sourceStream.map(mapper);
commonSource.filter(filter1).join(joiner1).flatMap(flatMapper1).sink(sink);
commonSource.filter(filter2).flatMap(flatMapper2).join(joiner1);
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
