This closes #2521: Add more unit test to Gearpump runner
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ebbb6139 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ebbb6139 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ebbb6139 Branch: refs/heads/gearpump-runner Commit: ebbb6139057deda05691fc357799506e5f9f3bf2 Parents: f4f2333 f3138dd Author: Kenneth Knowles <[email protected]> Authored: Tue Apr 18 13:25:20 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Tue Apr 18 13:25:20 2017 -0700 ---------------------------------------------------------------------- .../FlattenPCollectionsTranslator.java | 2 +- .../translators/GroupByKeyTranslator.java | 20 ++- .../translators/WindowAssignTranslator.java | 5 +- ...teGearpumpPCollectionViewTranslatorTest.java | 57 +++++++ .../CreatePCollectionViewTranslatorTest.java | 55 +++++++ .../FlattenPCollectionsTranslatorTest.java | 137 +++++++++++++++++ .../translators/GroupByKeyTranslatorTest.java | 151 +++++++++++++++++++ .../translators/ReadBoundedTranslatorTest.java | 70 +++++++++ .../ReadUnboundedTranslatorTest.java | 70 +++++++++ .../translators/WindowAssignTranslatorTest.java | 110 ++++++++++++++ .../translators/io/GearpumpSourceTest.java | 36 ++--- .../gearpump/translators/io/ValueSoureTest.java | 15 +- 12 files changed, 695 insertions(+), 33 deletions(-) ----------------------------------------------------------------------
