This closes #3283: [BEAM-3271] Add TestStream translation Add TestStream translation Expose internal constructors for TestStream events Add TestStreamPayload to Runner API proto Add translation convenience for non-composites
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0cba43ee Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0cba43ee Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0cba43ee Branch: refs/heads/master Commit: 0cba43ee26c00ae89f8e681f7fb1f0294aeadb0e Parents: 462335c 0cedc61 Author: Kenneth Knowles <k...@google.com> Authored: Sun Jun 4 21:30:10 2017 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Sun Jun 4 21:30:10 2017 -0700 ---------------------------------------------------------------------- .../construction/PTransformTranslation.java | 13 ++ .../construction/TestStreamTranslation.java | 156 +++++++++++++++++++ .../construction/TestStreamTranslationTest.java | 129 +++++++++++++++ .../src/main/proto/beam_runner_api.proto | 33 ++++ .../org/apache/beam/sdk/testing/TestStream.java | 60 +++++-- 5 files changed, 375 insertions(+), 16 deletions(-) ----------------------------------------------------------------------
