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

Class ShardedJobController<T extends IncrementalTask>

java.lang.Object

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

Type Parameters:

T - the type of the incremental task

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

WorkerController

public abstract class ShardedJobController<T extends IncrementalTask>
extends Object
implements Serializable

Aggregates results from IncrementalTasks and receives notification when the job completes.

Author:

ohler@google.com (Christian Ohler)

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ShardedJobController()

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	completed(Iterator<T> completedTasks) Called when the sharded job has completed successfully.
abstract void	failed(Status status) Called when the sharded job has failed to complete successfully.

Methods inherited from class java.lang.Object

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

Constructor Detail

ShardedJobController

public ShardedJobController()

Method Detail

completed

public abstract void completed(Iterator<T> completedTasks)

Called when the sharded job has completed successfully.

failed

public abstract void failed(Status status)

Called when the sharded job has failed to complete successfully.

Parameters:

status -