com.bigdata.service.mapred
Class AbstractReduceTask

java.lang.Object
  com.bigdata.service.mapred.AbstractReduceTask

All Implemented Interfaces:

IReduceTask, ITask, Serializable

Direct Known Subclasses:

CountKeywords

public abstract class AbstractReduceTask
extends Object
implements IReduceTask

Abstract base class for reduce tasks.

Version:

$Id: AbstractReduceTask.java 2265 2009-10-26 12:51:06Z thompsonbry $

Author:

Bryan Thompson

See Also:

Serialized Form

Field Summary

UUID	uuid The task identifier.

Constructor Summary

protected

AbstractReduceTask(UUID uuid, UUID dataService)

Method Summary

UUID	getDataService() The IDataService from which the reduce task will read its input.
UUID	getUUID() The unique identifier for the task.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bigdata.service.mapred.IReduceTask

reduce

Field Detail

uuid

public final UUID uuid

The task identifier.

Constructor Detail

AbstractReduceTask

protected AbstractReduceTask(UUID uuid,
                             UUID dataService)

Parameters:

uuid - The task identifier.

dataService - The data service identifier. The task will read its data from the index on the data service that is named by the task identifier.

Method Detail

getUUID

public UUID getUUID()

Description copied from interface: ITask

The unique identifier for the task.

Note: if a task is retried then the new instance of that task MUST have the same identifier.

Specified by:

getUUID in interface ITask

getDataService

public UUID getDataService()

Description copied from interface: IReduceTask

The IDataService from which the reduce task will read its input.

Specified by:

getDataService in interface IReduceTask