com.google.appengine.tools.mapreduce

Class MapJob<I,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.MapJob<I,O,R>

Type Parameters:

I - type of input values``

O - type of output values

R - type of final result

All Implemented Interfaces:

Serializable

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

A Pipeline job that runs a map jobs.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MapJob(MapSpecification<I,O,R> specification, MapSettings settings)

Method Summary

Methods

Modifier and Type	Method and Description
String	getJobDisplayName()
com.google.appengine.tools.pipeline.Value<MapReduceResult<R>>	handleException(CancellationException ex)
com.google.appengine.tools.pipeline.Value<MapReduceResult<R>>	handleException(Throwable t)
com.google.appengine.tools.pipeline.Value<MapReduceResult<R>>	run()
static <I,O,R> String	start(MapSpecification<I,O,R> specification, MapSettings settings) Starts a MapJob 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

MapJob

public MapJob(MapSpecification<I,O,R> specification,
      MapSettings settings)

Method Detail

start

public static <I,O,R> String start(MapSpecification<I,O,R> specification,
                   MapSettings settings)

Starts a MapJob 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(CancellationException ex)

Parameters:

ex - The cancellation exception

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