[SAMZA-915] Implement operator programming APIs to support linear pipeline

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Assignee: Yi Pan
• Reporter: Yi Pan
• Created: 24/Mar/16 22:22
• Updated: 22/Oct/16 04:43
• Resolved: 22/Oct/16 04:43

Description

This would include the programming APIs that support the following linear pipeline:

sourceStream.filter(filter).map(mapper).flatMap(flatMapper).sink(sink);

Issue Links

• duplicates: SAMZA-914 Design and implement a composable operator APIs for direct programming of DAG in Java