GitHub user Sanil15 opened a pull request: https://github.com/apache/samza/pull/501
Samza 1648: Integration Test Framework & Collection Stream Impl This patch provides the following: - TestRunner: Tesing Wrapper to run Samza job - CollectionStream: Acts as a stream descriptor for in memory collections - CollectionStreamSystem: System associated with a Collection - StreamUtils: Utilities over streams - Sample example of tests Link to SEP: https://cwiki.apache.org/confluence/display/SAMZA/SEP-12%3A+Integration+Test+Framework You can merge this pull request into a Git repository by running: $ git pull https://github.com/Sanil15/samza SAMZA-1648 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/samza/pull/501.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #501 ---- commit 06f7fc21a42576ba1682f5931f6f4d033d251581 Author: sanil15 <sanil.jain15@...> Date: 2018-05-02T18:09:14Z Initial Version Integration Test Framework with TestRunner for low level & high level api and implementation of CollectionStream commit 745cfe5f99765f8807bcc270b9a60439ccc4d9d2 Author: sanil15 <sanil.jain15@...> Date: 2018-05-02T18:18:25Z Merge branch 'master' into SAMZA-1648 ---- ---