You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by pr...@apache.org on 2016/05/13 21:30:39 UTC

[2/2] incubator-apex-malhar git commit: Merge branch 'APEXMALHAR-2081' of github.com:chandnisingh/incubator-apex-malhar

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 <pr...@datatorrent.com>
Authored: Fri May 13 14:10:46 2016 -0700
Committer: Priyanka Gugale <pr...@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(-)
----------------------------------------------------------------------