Closes #502
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e0cae9fb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e0cae9fb Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e0cae9fb Branch: refs/heads/master Commit: e0cae9fb691c53f5aeb1c43c52ff4354d4680f2e Parents: 8949ec3 b7e9a7e Author: Dan Halperin <dhalp...@google.com> Authored: Wed Jun 22 18:07:17 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Wed Jun 22 18:07:17 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/io/CompressedSource.java | 5 +++ .../apache/beam/sdk/io/OffsetBasedSource.java | 26 +++++++-------- .../beam/sdk/io/CompressedSourceTest.java | 35 ++++++++++++++++++++ 3 files changed, 53 insertions(+), 13 deletions(-) ----------------------------------------------------------------------
