com.google.appengine.tools.mapreduce.impl

Class WorkerController<I,O,R,C extends WorkerContext<O>>

java.lang.Object

com.google.appengine.tools.mapreduce.impl.shardedjob.ShardedJobController<WorkerShardTask<I,O,C>>

com.google.appengine.tools.mapreduce.impl.WorkerController<I,O,R,C>

All Implemented Interfaces:

Serializable

public class WorkerController<I,O,R,C extends WorkerContext<O>>
extends ShardedJobController<WorkerShardTask<I,O,C>>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WorkerController(String mrJobId, Counters initialCounters, Output<O,R> output, String resultPromiseHandle)

Method Summary

Methods

Modifier and Type	Method and Description
void	completed(Iterator<WorkerShardTask<I,O,C>> workers) Called when the sharded job has completed successfully.
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

WorkerController

public WorkerController(String mrJobId,
                Counters initialCounters,
                Output<O,R> output,
                String resultPromiseHandle)

Method Detail

completed

public void completed(Iterator<WorkerShardTask<I,O,C>> workers)

Description copied from class: ShardedJobController

Called when the sharded job has completed successfully.

Specified by:

completed in class ShardedJobController<WorkerShardTask<I,O,C extends WorkerContext<O>>>

failed

public void failed(Status status)

Description copied from class: ShardedJobController

Called when the sharded job has failed to complete successfully.

Specified by:

failed in class ShardedJobController<WorkerShardTask<I,O,C extends WorkerContext<O>>>