Author: jeastman
Date: Mon May 26 18:47:46 2008
New Revision: 660349
URL: http://svn.apache.org/viewvc?rev=660349&view=rev
Log:
MAHOUT-59: Removed output path deletion code from KMeansDriver and removed
deprecated fs.delete version from KMeansJob
KMeans tests still run.
Modified:
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansDriver.java
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansJob.java
Modified:
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansDriver.java
URL:
http://svn.apache.org/viewvc/lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansDriver.java?rev=660349&r1=660348&r2=660349&view=diff
==============================================================================
---
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansDriver.java
(original)
+++
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansDriver.java
Mon May 26 18:47:46 2008
@@ -60,14 +60,6 @@
public static void runJob(String input, String clustersIn, String output,
String measureClass, double convergenceDelta, int
maxIterations) {
try {
- // delete the output directory
- JobConf conf = new JobConf(KMeansDriver.class);
- Path outPath = new Path(output);
- FileSystem fs = FileSystem.get(conf);
- if (fs.exists(outPath)) {
- fs.delete(outPath, true);
- }
- fs.mkdirs(outPath);
// iterate until the clusters converge
boolean converged = false;
int iteration = 0;
Modified:
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansJob.java
URL:
http://svn.apache.org/viewvc/lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansJob.java?rev=660349&r1=660348&r2=660349&view=diff
==============================================================================
---
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansJob.java
(original)
+++
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansJob.java
Mon May 26 18:47:46 2008
@@ -55,7 +55,7 @@
Path outPath = new Path(output);
FileSystem fs = FileSystem.get(conf);
if (fs.exists(outPath)) {
- fs.delete(outPath);
+ fs.delete(outPath, true);
}
fs.mkdirs(outPath);
KMeansDriver.runJob(input, clustersIn, output, measureClass,
