You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/07/11 23:25:29 UTC
[2/2] beam git commit: This closes #3443: [BEAM-2511] Implements
TextIO.ReadAll
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 <ki...@google.com>
Authored: Tue Jul 11 16:12:40 2017 -0700
Committer: Eugene Kirpichov <ki...@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(-)
----------------------------------------------------------------------