You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/05/04 19:53:30 UTC
[05/50] [abbrv] beam git commit: [BEAM-2135] Move hdfs to
hadoop-file-system
[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/gearpump-runner
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(-)
----------------------------------------------------------------------