JIRA: [NEMO-213: Use Beam's DoFnRunners to execute 
DoFn](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-213)

**Major changes:**
- use `simpleDoFnRunner` to process events of `DoFn`
- convert all beam `Transform`s to process `WindowedValue`
- create a `BeamBoundedWindowedSourceVertex` that generates `WindowedValue`s
- modify `PipelineTranslator` to use the newly created `Transform`s 
(`SimpleDoFnTransform`...)

**Minor changes to note:**
- 

**Tests for the changes:**
- create a unit test that executes `SimpleDoFnTransform`

**Other comments:**
- We need a performance test 

Closes #GITHUB_PR_NUMBER


[ Full content available at: https://github.com/apache/incubator-nemo/pull/122 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to