You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ed...@apache.org on 2014/02/04 06:50:40 UTC
svn commit: r1564210 -
/hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java
Author: edwardyoon
Date: Tue Feb 4 05:50:39 2014
New Revision: 1564210
URL: http://svn.apache.org/r1564210
Log:
remove duplicated code.
Modified:
hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java
Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java?rev=1564210&r1=1564209&r2=1564210&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java Tue Feb 4 05:50:39 2014
@@ -274,8 +274,6 @@ public class PartitioningRunner extends
comparisonMap.clear();
writer.close();
-
- deleteSlices(status);
}
@SuppressWarnings({ "rawtypes", "unchecked" })
@@ -301,16 +299,6 @@ public class PartitioningRunner extends
reader.close();
}
writer.close();
-
- deleteSlices(status);
- }
-
- private void deleteSlices(FileStatus[] status) throws IOException {
- for (int i = 0; i < status.length; i++) {
- fs.delete(status[i].getPath(), true);
- if (fs.exists(status[i].getPath().suffix(".sorted")))
- fs.delete(status[i].getPath().suffix(".sorted"), true);
- }
}
@Override