Repository: incubator-apex-malhar Updated Branches: refs/heads/master 3ce83708f -> cf3bb7df0
APEXMALHAR-2013 Marked HDFSFileCopyModule and HDFSFileMerger as Evolving 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/c34ae415 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/c34ae415 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/c34ae415 Branch: refs/heads/master Commit: c34ae4159517b178191bf5c91ca76dafe95bff9f Parents: 45c6825 Author: Chandni Singh <[email protected]> Authored: Tue May 17 17:18:57 2016 -0700 Committer: Chandni Singh <[email protected]> Committed: Tue May 17 17:25:17 2016 -0700 ---------------------------------------------------------------------- .../src/main/java/com/datatorrent/lib/io/fs/HDFSFileCopyModule.java | 1 + library/src/main/java/com/datatorrent/lib/io/fs/HDFSFileMerger.java | 1 + 2 files changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/c34ae415/library/src/main/java/com/datatorrent/lib/io/fs/HDFSFileCopyModule.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/HDFSFileCopyModule.java b/library/src/main/java/com/datatorrent/lib/io/fs/HDFSFileCopyModule.java index a823812..87fd1e7 100644 --- a/library/src/main/java/com/datatorrent/lib/io/fs/HDFSFileCopyModule.java +++ b/library/src/main/java/com/datatorrent/lib/io/fs/HDFSFileCopyModule.java @@ -41,6 +41,7 @@ import com.datatorrent.netlet.util.Slice; * Essential operators are wrapped into single component using Module API. * */ [email protected] public class HDFSFileCopyModule implements Module { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/c34ae415/library/src/main/java/com/datatorrent/lib/io/fs/HDFSFileMerger.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/HDFSFileMerger.java b/library/src/main/java/com/datatorrent/lib/io/fs/HDFSFileMerger.java index 200801e..14918ec 100644 --- a/library/src/main/java/com/datatorrent/lib/io/fs/HDFSFileMerger.java +++ b/library/src/main/java/com/datatorrent/lib/io/fs/HDFSFileMerger.java @@ -38,6 +38,7 @@ import com.datatorrent.lib.io.fs.Synchronizer.OutputFileMetadata; * This uses fast merge from HDFS if destination filesystem is same as * application filesystem. */ [email protected] public class HDFSFileMerger extends FileMerger { /**
