[BEAM-2135] Move hdfs to hadoop-file-system This closes #2828
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9f6377fc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9f6377fc Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9f6377fc Branch: refs/heads/master Commit: 9f6377fcc1a996d5aa855f5c5755ec835804fbe4 Parents: 3161904 bacd33c Author: Luke Cwik <lc...@google.com> Authored: Tue May 2 12:58:25 2017 -0700 Committer: Luke Cwik <lc...@google.com> Committed: Tue May 2 12:58:25 2017 -0700 ---------------------------------------------------------------------- sdks/java/io/hadoop-file-system/README.md | 43 ++ sdks/java/io/hadoop-file-system/pom.xml | 195 ++++++ .../apache/beam/sdk/io/hdfs/HDFSFileSink.java | 478 ++++++++++++++ .../apache/beam/sdk/io/hdfs/HDFSFileSource.java | 625 +++++++++++++++++++ .../beam/sdk/io/hdfs/HadoopFileSystem.java | 240 +++++++ .../sdk/io/hdfs/HadoopFileSystemModule.java | 84 +++ .../sdk/io/hdfs/HadoopFileSystemOptions.java | 49 ++ .../hdfs/HadoopFileSystemOptionsRegistrar.java | 35 ++ .../sdk/io/hdfs/HadoopFileSystemRegistrar.java | 62 ++ .../beam/sdk/io/hdfs/HadoopResourceId.java | 81 +++ .../java/org/apache/beam/sdk/io/hdfs/Sink.java | 195 ++++++ .../org/apache/beam/sdk/io/hdfs/UGIHelper.java | 38 ++ .../java/org/apache/beam/sdk/io/hdfs/Write.java | 585 +++++++++++++++++ .../apache/beam/sdk/io/hdfs/package-info.java | 22 + .../beam/sdk/io/hdfs/HDFSFileSinkTest.java | 172 +++++ .../beam/sdk/io/hdfs/HDFSFileSourceTest.java | 231 +++++++ .../sdk/io/hdfs/HadoopFileSystemModuleTest.java | 65 ++ .../HadoopFileSystemOptionsRegistrarTest.java | 49 ++ .../io/hdfs/HadoopFileSystemOptionsTest.java | 48 ++ .../io/hdfs/HadoopFileSystemRegistrarTest.java | 81 +++ .../beam/sdk/io/hdfs/HadoopFileSystemTest.java | 247 ++++++++ sdks/java/io/hdfs/README.md | 43 -- sdks/java/io/hdfs/pom.xml | 195 ------ .../apache/beam/sdk/io/hdfs/HDFSFileSink.java | 478 -------------- .../apache/beam/sdk/io/hdfs/HDFSFileSource.java | 625 ------------------- .../beam/sdk/io/hdfs/HadoopFileSystem.java | 240 ------- .../sdk/io/hdfs/HadoopFileSystemModule.java | 84 --- .../sdk/io/hdfs/HadoopFileSystemOptions.java | 49 -- .../hdfs/HadoopFileSystemOptionsRegistrar.java | 35 -- .../sdk/io/hdfs/HadoopFileSystemRegistrar.java | 62 -- .../beam/sdk/io/hdfs/HadoopResourceId.java | 81 --- .../java/org/apache/beam/sdk/io/hdfs/Sink.java | 195 ------ .../org/apache/beam/sdk/io/hdfs/UGIHelper.java | 38 -- .../java/org/apache/beam/sdk/io/hdfs/Write.java | 585 ----------------- .../apache/beam/sdk/io/hdfs/package-info.java | 22 - .../beam/sdk/io/hdfs/HDFSFileSinkTest.java | 172 ----- .../beam/sdk/io/hdfs/HDFSFileSourceTest.java | 231 ------- .../sdk/io/hdfs/HadoopFileSystemModuleTest.java | 65 -- .../HadoopFileSystemOptionsRegistrarTest.java | 49 -- .../io/hdfs/HadoopFileSystemOptionsTest.java | 48 -- .../io/hdfs/HadoopFileSystemRegistrarTest.java | 81 --- .../beam/sdk/io/hdfs/HadoopFileSystemTest.java | 247 -------- sdks/java/io/pom.xml | 2 +- 43 files changed, 3626 insertions(+), 3626 deletions(-) ----------------------------------------------------------------------