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

Class ShardedJobRunner<T extends IncrementalTask>

java.lang.Object

com.google.appengine.tools.mapreduce.impl.shardedjob.ShardedJobRunner<T>

Type Parameters:

T - type of tasks that the job being processed consists of

All Implemented Interfaces:

ShardedJobHandler

public class ShardedJobRunner<T extends IncrementalTask>
extends Object
implements ShardedJobHandler

Contains all logic to manage and run sharded jobs. This is a helper class for ShardedJobServiceImpl that implements all the functionality but assumes fixed types for <T>.

Author:

ohler@google.com (Christian Ohler)

Field Summary

Fields

Modifier and Type	Field and Description
static com.google.appengine.tools.cloudstorage.RetryParams	DATASTORE_RETRY_FOREVER_PARAMS
static com.google.appengine.tools.cloudstorage.ExceptionHandler	EXCEPTION_HANDLER

Fields inherited from interface com.google.appengine.tools.mapreduce.impl.shardedjob.ShardedJobHandler

JOB_ID_PARAM, SEQUENCE_NUMBER_PARAM, TASK_ID_PARAM

Constructor Summary

Constructors

Constructor and Description
ShardedJobRunner()

Method Summary

Methods

Modifier and Type	Method and Description
void	completeShard(String jobId, String taskId) Is invoked by the servlet that handles ShardedJobSettings.getControllerPath() when a shard has completed.
static String	getTaskId(String jobId, int taskNumber)
void	runTask(String jobId, String taskId, int sequenceNumber) Is invoked by the servlet that handles ShardedJobSettings.getWorkerPath() to run a task.

Methods inherited from class java.lang.Object

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

Field Detail

DATASTORE_RETRY_FOREVER_PARAMS

public static final com.google.appengine.tools.cloudstorage.RetryParams DATASTORE_RETRY_FOREVER_PARAMS

EXCEPTION_HANDLER

public static final com.google.appengine.tools.cloudstorage.ExceptionHandler EXCEPTION_HANDLER

Constructor Detail

ShardedJobRunner

public ShardedJobRunner()

Method Detail

completeShard

public void completeShard(String jobId,
                 String taskId)

Description copied from interface: ShardedJobHandler

Is invoked by the servlet that handles ShardedJobSettings.getControllerPath() when a shard has completed.

Specified by:

completeShard in interface ShardedJobHandler

runTask

public void runTask(String jobId,
           String taskId,
           int sequenceNumber)

Description copied from interface: ShardedJobHandler

Is invoked by the servlet that handles ShardedJobSettings.getWorkerPath() to run a task.

Specified by:

runTask in interface ShardedJobHandler

getTaskId

public static String getTaskId(String jobId,
               int taskNumber)