hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cutt...@apache.org
Subject svn commit: r400104 - in /lucene/hadoop/trunk/src: examples/org/apache/hadoop/examples/ExampleDriver.java java/org/apache/hadoop/mapred/ClusterStatus.java java/org/apache/hadoop/mapred/JobClient.java
Date Fri, 05 May 2006 16:28:45 GMT
Author: cutting
Date: Fri May  5 09:28:40 2006
New Revision: 400104

URL: http://svn.apache.org/viewcvs?rev=400104&view=rev
Log:
HADOOP-198.  Add more example programs to example driver.  Also fix another WritableFactories-related
error.  Contributed by Mahadev.

Modified:
    lucene/hadoop/trunk/src/examples/org/apache/hadoop/examples/ExampleDriver.java
    lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ClusterStatus.java
    lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobClient.java

Modified: lucene/hadoop/trunk/src/examples/org/apache/hadoop/examples/ExampleDriver.java
URL: http://svn.apache.org/viewcvs/lucene/hadoop/trunk/src/examples/org/apache/hadoop/examples/ExampleDriver.java?rev=400104&r1=400103&r2=400104&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/examples/org/apache/hadoop/examples/ExampleDriver.java (original)
+++ lucene/hadoop/trunk/src/examples/org/apache/hadoop/examples/ExampleDriver.java Fri May
 5 09:28:40 2006
@@ -33,7 +33,10 @@
 			 "A map/reduce program that counts the words in the input files.");
 	    pgd.addClass("grep", Grep.class, 
 			 "A map/reduce program that counts the matches of a regex in the input.");
-	    pgd.driver(argv);
+	    pgd.addClass("randomwriter", RandomWriter.class, 
+                        "A random writer benchmark that writes 10GB per node.");
+            pgd.addClass("sort", Sort.class, "A sort benchmark that sorts the data written
by the random writer.");
+            pgd.driver(argv);
 	}
 	catch(Throwable e){
 	    e.printStackTrace();

Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ClusterStatus.java
URL: http://svn.apache.org/viewcvs/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ClusterStatus.java?rev=400104&r1=400103&r2=400104&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ClusterStatus.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ClusterStatus.java Fri May  5 09:28:40
2006
@@ -27,7 +27,7 @@
   private int reduce_tasks;
   private int max_tasks;
 
-  private ClusterStatus() {}
+  ClusterStatus() {}
   
   ClusterStatus(int trackers, int maps, int reduces, int max) {
     task_trackers = trackers;

Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobClient.java
URL: http://svn.apache.org/viewcvs/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobClient.java?rev=400104&r1=400103&r2=400104&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobClient.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobClient.java Fri May  5 09:28:40
2006
@@ -39,7 +39,7 @@
     static long MAX_JOBPROFILE_AGE = 1000 * 2;
 
     // required for unknown reason to make WritableFactories work distributed
-    static { new JobStatus(); new JobProfile(); }
+    static { new JobStatus(); new JobProfile(); new ClusterStatus(); }
 
     /**
      * A NetworkedJob is an implementation of RunningJob.  It holds



Mime
View raw message