com.google.appengine.tools.mapreduce

Class MapReduceJob<I,K,V,O,R>

java.lang.Object

com.google.appengine.tools.pipeline.Job<T>

com.google.appengine.tools.pipeline.Job0<MapReduceResult<R>>

com.google.appengine.tools.mapreduce.MapReduceJob<I,K,V,O,R>

Type Parameters:

I - type of input values

K - type of intermediate keys

V - type of intermediate values

O - type of output values

R - type of final result

All Implemented Interfaces:

Serializable

public class MapReduceJob<I,K,V,O,R>
extends com.google.appengine.tools.pipeline.Job0<MapReduceResult<R>>

A Pipeline job that runs a MapReduce.

Author:

ohler@google.com (Christian Ohler)

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MapReduceJob(MapReduceSpecification<I,K,V,O,R> specification, MapReduceSettings settings)

Method Summary

Methods

Modifier and Type	Method and Description
String	getJobDisplayName()
com.google.appengine.tools.pipeline.Value<MapReduceResult<R>>	handleException(Throwable t)
com.google.appengine.tools.pipeline.Value<MapReduceResult<R>>	run()
static <I,K,V,O,R> String	start(MapReduceSpecification<I,K,V,O,R> specification, MapReduceSettings settings) Starts a MapReduceJob with the given parameters in a new Pipeline.

Methods inherited from class com.google.appengine.tools.pipeline.Job

backOffFactor, backOffSeconds, futureCall, futureCall, futureCall, futureCall, futureCall, futureCall, futureCall, futureCallUnchecked, futureList, getJobKey, getOnBackend, getOnModule, getOnQueue, getPipelineKey, getStatusConsoleUrl, immediate, maxAttempts, newDelayedValue, newPromise, newPromise, onBackend, onModule, onQueue, setStatusConsoleUrl, statusConsoleUrl, waitFor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MapReduceJob

public MapReduceJob(MapReduceSpecification<I,K,V,O,R> specification,
            MapReduceSettings settings)

Method Detail

start

public static <I,K,V,O,R> String start(MapReduceSpecification<I,K,V,O,R> specification,
                       MapReduceSettings settings)

Starts a MapReduceJob with the given parameters in a new Pipeline. Returns the pipeline id.

run

public com.google.appengine.tools.pipeline.Value<MapReduceResult<R>> run()

Specified by:

run in class com.google.appengine.tools.pipeline.Job0<MapReduceResult<R>>

handleException

public com.google.appengine.tools.pipeline.Value<MapReduceResult<R>> handleException(Throwable t)
                                                                              throws Throwable

Throws:

Throwable

getJobDisplayName

public String getJobDisplayName()

Overrides:

getJobDisplayName in class com.google.appengine.tools.pipeline.Job<MapReduceResult<R>>