From 3896dfbb4a8bffe797896c701b42e16d370ac797 Mon Sep 17 00:00:00 2001
From: mcilwain <mcilwain@google.com>
Date: Fri, 8 Jul 2016 08:31:59 -0700
Subject: [PATCH] Write list of iOS apps for IRDB to fetch to GCS -------------
 Created by MOE: https://github.com/google/moe MOE_MIGRATED_REVID=126914056

---
 .../registry/mapreduce/MapreduceRunner.java   | 30 ++++++++++++++++---
 1 file changed, 26 insertions(+), 4 deletions(-)

diff --git a/java/google/registry/mapreduce/MapreduceRunner.java b/java/google/registry/mapreduce/MapreduceRunner.java
index d5a80cdc4..06ab73816 100644
--- a/java/google/registry/mapreduce/MapreduceRunner.java
+++ b/java/google/registry/mapreduce/MapreduceRunner.java
@@ -186,8 +186,8 @@ public class MapreduceRunner {
       createMapreduceJob(
           Mapper<I, K, V> mapper,
           Reducer<K, V, O> reducer,
-          Output<O, R> output,
-          Iterable<? extends Input<? extends I>> inputs) {
+          Iterable<? extends Input<? extends I>> inputs,
+          Output<O, R> output) {
     checkCommonRequiredFields(inputs, mapper);
     checkArgumentNotNull(reducer, "reducer");
     return new MapReduceJob<>(
@@ -229,8 +229,30 @@ public class MapreduceRunner {
       Mapper<I, K, V> mapper,
       Reducer<K, V, Void> reducer,
       Iterable<? extends Input<? extends I>> inputs) {
-    return runAsPipeline(
-        createMapreduceJob(mapper, reducer, new NoOutput<Void, Void>(), inputs));
+    return runMapreduce(mapper, reducer, inputs, new NoOutput<Void, Void>());
+  }
+
+  /**
+   * Kick off a mapreduce job with specified Output handler.
+   *
+   * @see #createMapreduceJob for creating and running a mapreduce as part of a pipeline
+   *
+   * @param mapper instance of a mapper class
+   * @param reducer instance of a reducer class
+   * @param inputs input sources for the mapper
+   * @param <I> mapper input type
+   * @param <K> emitted key type
+   * @param <V> emitted value type
+   * @param <O> emitted output type
+   * @param <R> return value of output
+   * @return the job id
+   */
+  public final <I, K extends Serializable, V extends Serializable, O, R> String runMapreduce(
+      Mapper<I, K, V> mapper,
+      Reducer<K, V, O> reducer,
+      Iterable<? extends Input<? extends I>> inputs,
+      Output<O, R> output) {
+    return runAsPipeline(createMapreduceJob(mapper, reducer, inputs, output));
   }
 
   private void checkCommonRequiredFields(Iterable<?> inputs, Mapper<?, ?, ?> mapper) {