beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [5/5] beam git commit: [BEAM-2135] Move hdfs to hadoop-file-system
Date Tue, 02 May 2017 19:58:37 GMT
[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 <lcwik@google.com>
Authored: Tue May 2 12:58:25 2017 -0700
Committer: Luke Cwik <lcwik@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(-)
----------------------------------------------------------------------



Mime
View raw message