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){