This closes #1944
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e2ef2d02 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e2ef2d02 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e2ef2d02 Branch: refs/heads/master Commit: e2ef2d020e1f9f40b79e122807fb98a31e1f439e Parents: d4db4fb adba4c6 Author: Dan Halperin <dhalp...@google.com> Authored: Mon Feb 13 08:14:09 2017 -0800 Committer: Dan Halperin <dhalp...@google.com> Committed: Mon Feb 13 08:14:09 2017 -0800 ---------------------------------------------------------------------- .../examples/complete/TopWikipediaSessions.java | 25 +- .../FlinkStreamingTransformTranslators.java | 18 +- .../spark/translation/TransformTranslator.java | 12 +- .../java/org/apache/beam/sdk/io/TextIO.java | 383 +++++++------------ .../java/org/apache/beam/sdk/io/TextIOTest.java | 164 +++----- 5 files changed, 240 insertions(+), 362 deletions(-) ----------------------------------------------------------------------
