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

Interface Summary

Interface	Description
IncrementalTask	Portion of a sharded job that will be run in a single task queue task.
ShardedJobHandler	As part of its operation, the ShardedJobService will enqueue task queue tasks that send requests to the URLs specified in ShardedJobSettings.
ShardedJobService	Allows interaction with sharded jobs.
ShardedJobState	Information about execution and progress of a sharded job.

Class Summary

Class	Description
IncrementalTaskState<T extends IncrementalTask>	Information about execution of an IncrementalTask.
IncrementalTaskState.Serializer	Utility class to serialize/deserialize IncrementalTaskState.
InProcessShardedJobRunner	Runs a sharded job in the current process.
ShardedJobController<T extends IncrementalTask>	Aggregates results from IncrementalTasks and receives notification when the job completes.
ShardedJobRunner<T extends IncrementalTask>	Contains all logic to manage and run sharded jobs.
ShardedJobServiceFactory	Provides ShardedJobService implementations.
ShardedJobSettings	Execution settings for a sharded job.
ShardedJobSettings.Builder	ShardedJobSettings builder.
ShardRetryState<T extends IncrementalTask>	Retry information for a shard.
ShardRetryState.Serializer	Utility class to serialize/deserialize ShardRetryState.
Status	Possible job statuses.

Enum Summary

Enum	Description
Status.StatusCode	The possible status codes for Status.

Exception Summary

Exception	Description
JobFailureException	An exception thrown when there should be no more attempts to continue processing the job.
RecoverableException	An exception that indicates it is safe to restart a slice.
RejectRequestException	An exception thrown to reject the current request with an error code (50X) This will usually cause taskqueue to retry the request on another instance.
ShardFailureException	An exception thrown when there should be no more attempts to continue processing the shard.