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/devel-3 Commit: becee7f82dbca5d975d92dc45ba5f771f8682ea8 Parents: 51a19e1 f9fe3d5 Author: ishark <[email protected]> Authored: Wed Mar 16 15:30:26 2016 -0700 Committer: ishark <[email protected]> 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(-) ----------------------------------------------------------------------
