You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by is...@apache.org on 2016/03/17 08:57:23 UTC
[2/2] incubator-apex-malhar git commit: Merge branch
'APEXMALHAR-2008-hdfs-input-module' of
https://github.com/DT-Priyanka/incubator-apex-malhar
Merge branch 'APEXMALHAR-2008-hdfs-input-module' of https://github.com/DT-Priyanka/incubator-apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/becee7f8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/becee7f8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/becee7f8
Branch: refs/heads/master
Commit: becee7f82dbca5d975d92dc45ba5f771f8682ea8
Parents: 51a19e1 f9fe3d5
Author: ishark <is...@datatorrent.com>
Authored: Wed Mar 16 15:30:26 2016 -0700
Committer: ishark <is...@datatorrent.com>
Committed: Wed Mar 16 15:30:26 2016 -0700
----------------------------------------------------------------------
.../datatorrent/lib/io/block/BlockMetadata.java | 31 ++-
.../datatorrent/lib/io/block/BlockReader.java | 66 +++++
.../lib/io/fs/AbstractFileSplitter.java | 45 +++-
.../lib/io/fs/FileSplitterInput.java | 81 +++++--
.../datatorrent/lib/io/fs/HDFSFileSplitter.java | 120 +++++++++
.../datatorrent/lib/io/fs/HDFSInputModule.java | 243 +++++++++++++++++++
.../lib/io/fs/FileSplitterInputTest.java | 2 +-
.../lib/io/fs/HDFSInputModuleAppTest.java | 221 +++++++++++++++++
8 files changed, 786 insertions(+), 23 deletions(-)
----------------------------------------------------------------------