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

Interface ShardedJobHandler

All Known Implementing Classes:

ShardedJobRunner

public interface ShardedJobHandler

As part of its operation, the ShardedJobService will enqueue task queue tasks that send requests to the URLs specified in ShardedJobSettings. It is the user's responsibility to arrange for these requests to be passed back into completeShard(java.lang.String, java.lang.String) and runTask(java.lang.String, java.lang.String, int).

Field Summary

Fields

Modifier and Type	Field and Description
static String	JOB_ID_PARAM
static String	SEQUENCE_NUMBER_PARAM
static String	TASK_ID_PARAM

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.
void	runTask(String jobId, String taskId, int sequenceNumber) Is invoked by the servlet that handles ShardedJobSettings.getWorkerPath() to run a task.

Field Detail

JOB_ID_PARAM

static final String JOB_ID_PARAM

See Also:

Constant Field Values

TASK_ID_PARAM

static final String TASK_ID_PARAM

See Also:

Constant Field Values

SEQUENCE_NUMBER_PARAM

static final String SEQUENCE_NUMBER_PARAM

See Also:

Constant Field Values

Method Detail

completeShard

void completeShard(String jobId,
                 String taskId)

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

runTask

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

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