You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/06/05 04:48:32 UTC
[5/5] beam git commit: This closes #3283: [BEAM-3271] Add TestStream
translation
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 <kl...@google.com>
Authored: Sun Jun 4 21:30:10 2017 -0700
Committer: Kenneth Knowles <kl...@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(-)
----------------------------------------------------------------------