[jira] [Created] (SAMZA-916) Design and implement operator programing APIs to support split and join

["Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org>]

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)