com.google.appengine.tools.mapreduce.impl.pipeline

Class ShardedJob<T extends IncrementalTask>

java.lang.Object

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

com.google.appengine.tools.pipeline.Job0<Void>

com.google.appengine.tools.mapreduce.impl.pipeline.ShardedJob<T>

Type Parameters:

T - type of task

All Implemented Interfaces:

Serializable

public class ShardedJob<T extends IncrementalTask>
extends com.google.appengine.tools.pipeline.Job0<Void>

ShardedJob pipeline.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ShardedJob(String shardedJobId, List<? extends T> workers, ShardedJobController<T> controller, ShardedJobSettings shardedJobSettings)

Method Summary

Methods

Modifier and Type	Method and Description
com.google.appengine.tools.pipeline.Value<Void>	run()

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

backOffFactor, backOffSeconds, futureCall, futureCall, futureCall, futureCall, futureCall, futureCall, futureCall, futureCallUnchecked, futureList, getJobDisplayName, 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

ShardedJob

public ShardedJob(String shardedJobId,
          List<? extends T> workers,
          ShardedJobController<T> controller,
          ShardedJobSettings shardedJobSettings)

Method Detail

run

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

Specified by:

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