Merge branch 'APEXMALHAR-2081' of github.com:chandnisingh/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/af6075bf Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/af6075bf Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/af6075bf Branch: refs/heads/master Commit: af6075bfa01fd45fa29d2f331ae93e29a976c5a1 Parents: 2459f6c b037ae2 Author: Priyanka Gugale <priya...@datatorrent.com> Authored: Fri May 13 14:10:46 2016 -0700 Committer: Priyanka Gugale <priya...@datatorrent.com> Committed: Fri May 13 14:10:46 2016 -0700 ---------------------------------------------------------------------- .../datatorrent/apps/copy/HDFSFileCopyApp.java | 4 +- .../lib/io/block/AbstractBlockReader.java | 6 + .../lib/io/block/AbstractFSBlockReader.java | 26 ++- .../datatorrent/lib/io/block/BlockMetadata.java | 28 --- .../datatorrent/lib/io/block/BlockReader.java | 66 ------ .../datatorrent/lib/io/fs/FSFileSplitter.java | 130 ----------- .../datatorrent/lib/io/fs/FSInputModule.java | 40 +++- .../lib/io/fs/FileSplitterInput.java | 37 ++++ .../datatorrent/lib/io/fs/HDFSFileSplitter.java | 37 ---- .../datatorrent/lib/io/fs/HDFSInputModule.java | 49 ---- .../lib/io/fs/FSInputModuleAppTest.java | 221 +++++++++++++++++++ .../lib/io/fs/HDFSInputModuleAppTest.java | 221 ------------------- 12 files changed, 321 insertions(+), 544 deletions(-) ----------------------------------------------------------------------
