You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by hi...@apache.org on 2013/04/27 01:33:59 UTC

svn commit: r1476450 - /incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/ExampleDriver.java

Author: hitesh
Date: Fri Apr 26 23:33:58 2013
New Revision: 1476450

URL: http://svn.apache.org/r1476450
Log:
TEZ-89. Add MRR example job.

Modified:
    incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/ExampleDriver.java

Modified: incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/ExampleDriver.java
URL: http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/ExampleDriver.java?rev=1476450&r1=1476449&r2=1476450&view=diff
==============================================================================
--- incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/ExampleDriver.java (original)
+++ incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/ExampleDriver.java Fri Apr 26 23:33:58 2013
@@ -34,20 +34,33 @@ public class ExampleDriver {
     ProgramDriver pgd = new ProgramDriver();
     try {
       pgd.addClass("wordcount", WordCount.class, 
-                   "A map/reduce program that counts the words in the input files.");
+          "A map/reduce program that counts the words in the input files.");
       pgd.addClass("wordcountmrrtest", WordCountMRRTest.class, 
-          "A map/reduce program that counts the words in the input files. Map splits on spaces. First reduce splits on \".\"");
+          "A map/reduce program that counts the words in the input files."
+          + " Map splits on spaces. First reduce splits on \".\"");
       pgd.addClass("randomwriter", RandomWriter.class, 
-                   "A map/reduce program that writes 10GB of random data per node.");
+          "A map/reduce program that writes 10GB of random data per node.");
       pgd.addClass("randomtextwriter", RandomTextWriter.class, 
       "A map/reduce program that writes 10GB of random textual data per node.");
-      pgd.addClass("sort", Sort.class, "A map/reduce program that sorts the data written by the random writer.");
+      pgd.addClass("sort", Sort.class,
+          "A map/reduce program that sorts the data written by the random"
+          + " writer.");
       pgd.addClass("secondarysort", SecondarySort.class,
-                   "An example defining a secondary sort to the reduce.");
-      pgd.addClass("join", Join.class, "A job that effects a join over sorted, equally partitioned datasets");
-      pgd.addClass("teragen", TeraGen.class, "Generate data for the terasort");
-      pgd.addClass("terasort", TeraSort.class, "Run the terasort");
-      pgd.addClass("teravalidate", TeraValidate.class, "Checking results of terasort");
+          "An example defining a secondary sort to the reduce.");
+      pgd.addClass("join", Join.class,
+          "A job that effects a join over sorted, equally partitioned"
+          + " datasets");
+      pgd.addClass("teragen", TeraGen.class,
+          "Generate data for the terasort");
+      pgd.addClass("terasort", TeraSort.class,
+          "Run the terasort");
+      pgd.addClass("teravalidate", TeraValidate.class,
+          "Checking results of terasort");
+      pgd.addClass("groupbyorderbymrrtest", GroupByOrderByMRRTest.class,
+          "A map-reduce-reduce program that does groupby-order by. Takes input"
+          + " containing employee_name department name per line of input"
+          + " and generates count of employees per department and"
+          + " sorted on employee count");
       exitCode = pgd.driver(argv);
     }
     catch(Throwable e){