[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 <[email protected]> Authored: Thu Aug 3 12:19:49 2017 -0700 Committer: Luke Cwik <[email protected]> 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(+) ----------------------------------------------------------------------
