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

Class AbstractShardedJob

java.lang.Object

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

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

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

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

DeleteShardedJob, FinalizeShardedJob

public abstract class AbstractShardedJob
extends com.google.appengine.tools.pipeline.Job0<Void>

A base class for a sharded-job pipeline.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AbstractShardedJob(String jobId, int taskCount)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract com.google.appengine.tools.pipeline.Job<?>	createShardsJob(int start, int end)
protected com.google.appengine.tools.pipeline.JobSetting[]	getChildJobParams()
protected String	getJobId()
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

AbstractShardedJob

public AbstractShardedJob(String jobId,
                  int taskCount)

Method Detail

run

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

Specified by:

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

createShardsJob

protected abstract com.google.appengine.tools.pipeline.Job<?> createShardsJob(int start,
                                                         int end)

getJobId

protected String getJobId()

getChildJobParams

protected com.google.appengine.tools.pipeline.JobSetting[] getChildJobParams()