This closes #3737: [BEAM-2781] Adds a canonical Compression enum for file-based IOs
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5cb7be78 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5cb7be78 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5cb7be78 Branch: refs/heads/master Commit: 5cb7be78bf1871e8ca17cbe00ad1d154f20f9c22 Parents: afe8b0e 54489f0 Author: Eugene Kirpichov <ekirpic...@gmail.com> Authored: Wed Aug 30 17:42:17 2017 -0700 Committer: Eugene Kirpichov <ekirpic...@gmail.com> Committed: Wed Aug 30 17:42:17 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/AvroSink.java | 2 +- .../apache/beam/sdk/io/CompressedSource.java | 292 ++++++------------- .../org/apache/beam/sdk/io/Compression.java | 228 +++++++++++++++ .../org/apache/beam/sdk/io/FileBasedSink.java | 113 +++---- .../java/org/apache/beam/sdk/io/TFRecordIO.java | 153 ++++------ .../java/org/apache/beam/sdk/io/TextIO.java | 178 +++++------ .../beam/sdk/io/CompressedSourceTest.java | 17 +- .../apache/beam/sdk/io/FileBasedSinkTest.java | 41 ++- .../java/org/apache/beam/sdk/io/SimpleSink.java | 23 +- .../org/apache/beam/sdk/io/TFRecordIOTest.java | 35 ++- .../org/apache/beam/sdk/io/TextIOReadTest.java | 81 +++-- .../org/apache/beam/sdk/io/WriteFilesTest.java | 9 +- .../java/org/apache/beam/sdk/io/xml/XmlIO.java | 96 +++--- 13 files changed, 672 insertions(+), 596 deletions(-) ----------------------------------------------------------------------
