svn commit: r1300809 - /incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java

[jd...@apache.org]

Author: jdonofrio
Date: Thu Mar 15 03:48:51 2012
New Revision: 1300809

URL: http://svn.apache.org/viewvc?rev=1300809&view=rev
Log:
MRUNIT-89: add static convenience methods to PipelineMapReduceDriver class

Modified:
    incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java

Modified: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java?rev=1300809&r1=1300808&r2=1300809&view=diff
==============================================================================
--- incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java (original)
+++ incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java Thu Mar 15 03:48:51 2012
@@ -404,4 +404,27 @@ public class PipelineMapReduceDriver<K1,
       throw new RuntimeException(ioe);
     }
   }
+
+  /**
+   * Returns a new PipelineMapReduceDriver without having to specify the generic
+   * types on the right hand side of the object create statement.
+   * 
+   * @return new PipelineMapReduceDriver
+   */
+  public static <K1, V1, K2, V2> PipelineMapReduceDriver<K1, V1, K2, V2> newPipelineMapReduceDriver() {
+    return new PipelineMapReduceDriver<K1, V1, K2, V2>();
+  }
+
+  /**
+   * Returns a new PipelineMapReduceDriver without having to specify the generic
+   * types on the right hand side of the object create statement.
+   * 
+   * @param pipeline
+   *          passed to PipelineMapReduceDriver constructor
+   * @return new PipelineMapReduceDriver
+   */
+  public static <K1, V1, K2, V2> PipelineMapReduceDriver<K1, V1, K2, V2> newPipelineMapReduceDriver(
+      final List<Pair<Mapper, Reducer>> pipeline) {
+    return new PipelineMapReduceDriver<K1, V1, K2, V2>(pipeline);
+  }
 }