Closes #1139
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/989e3998 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/989e3998 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/989e3998 Branch: refs/heads/apex-runner Commit: 989e399874a5f0ebcf7c19f24a7fd18cead7bfba Parents: 0a1b278 7105d92 Author: Thomas Weise <[email protected]> Authored: Tue Oct 25 11:01:15 2016 -0700 Committer: Thomas Weise <[email protected]> Committed: Tue Oct 25 11:01:15 2016 -0700 ---------------------------------------------------------------------- .../translators/ParDoBoundMultiTranslator.java | 14 ++- .../functions/ApexFlattenOperator.java | 3 +- .../translators/ParDoBoundTranslatorTest.java | 96 +++++++++++++++++++- 3 files changed, 107 insertions(+), 6 deletions(-) ----------------------------------------------------------------------
