You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/08/03 19:19:59 UTC
[2/2] beam git commit: [BEAM-1347] Add utility to be able to model
inbound reading as a single input stream
[BEAM-1347] Add utility to be able to model inbound reading as a single input stream
This closes #3638
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/38f18906
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/38f18906
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/38f18906
Branch: refs/heads/master
Commit: 38f18906335c5ed4cebd1dddb6f94688589670a4
Parents: d4f9e92 ac7f973
Author: Luke Cwik <lc...@google.com>
Authored: Thu Aug 3 12:19:49 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Thu Aug 3 12:19:49 2017 -0700
----------------------------------------------------------------------
.../beam/fn/harness/stream/DataStreams.java | 158 +++++++++++++++++++
.../beam/fn/harness/stream/DataStreamsTest.java | 92 +++++++++++
2 files changed, 250 insertions(+)
----------------------------------------------------------------------