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/18 22:00:25 UTC
[2/2] beam git commit: [BEAM-1347] Convert an InputStream into an
Iterable using the Beam Fn data specification
[BEAM-1347] Convert an InputStream into an Iterable<T> using the Beam Fn data specification
This closes #3724
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/95cd37fa
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/95cd37fa
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/95cd37fa
Branch: refs/heads/master
Commit: 95cd37faff1c57dc4184ed001d8d168bc42d174e
Parents: ae9a2dc b949aa1
Author: Luke Cwik <lc...@google.com>
Authored: Fri Aug 18 15:00:15 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Fri Aug 18 15:00:15 2017 -0700
----------------------------------------------------------------------
.../beam/fn/harness/stream/DataStreams.java | 73 +++++++-
.../beam/fn/harness/stream/DataStreamsTest.java | 165 ++++++++++++++-----
2 files changed, 192 insertions(+), 46 deletions(-)
----------------------------------------------------------------------