This closes #3443: [BEAM-2511] Implements TextIO.ReadAll
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/84682109 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/84682109 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/84682109 Branch: refs/heads/master Commit: 84682109b9ff186f8c850a0b71de5163949c2769 Parents: 011e279 cd216f7 Author: Eugene Kirpichov <kirpic...@google.com> Authored: Tue Jul 11 16:12:40 2017 -0700 Committer: Eugene Kirpichov <kirpic...@google.com> Committed: Tue Jul 11 16:12:40 2017 -0700 ---------------------------------------------------------------------- ...ndedSplittableProcessElementInvokerTest.java | 2 +- .../core/SplittableParDoProcessFnTest.java | 2 +- .../DataflowPipelineTranslatorTest.java | 2 +- .../apache/beam/sdk/io/CompressedSource.java | 40 ++-- .../apache/beam/sdk/io/OffsetBasedSource.java | 22 +- .../java/org/apache/beam/sdk/io/TextIO.java | 230 +++++++++++++++++-- .../apache/beam/sdk/io/range/OffsetRange.java | 101 ++++++++ .../beam/sdk/io/range/OffsetRangeTracker.java | 3 + .../transforms/splittabledofn/OffsetRange.java | 77 ------- .../splittabledofn/OffsetRangeTracker.java | 1 + .../java/org/apache/beam/sdk/io/TextIOTest.java | 62 +++-- .../beam/sdk/transforms/SplittableDoFnTest.java | 2 +- .../splittabledofn/OffsetRangeTrackerTest.java | 1 + 13 files changed, 387 insertions(+), 158 deletions(-) ----------------------------------------------------------------------
