com.cliftonsnyder.clutch.mr.task
Class MRTask

java.lang.Object
  com.cliftonsnyder.clutch.task.Task
      com.cliftonsnyder.clutch.mr.task.MRTask

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

MapTask, ReduceTask

public abstract class MRTask
extends Task

An abstraction for MapReduce-specific tasks (MapTask, ReduceTask)

Author:

Clifton L. Snyder

See Also:

Serialized Form

Field Summary

protected java.util.List<Pair<java.lang.Comparable,java.lang.Object>>

keyValuePairs

Constructor Summary

MRTask()

Method Summary

void	addKeyValuePair(Pair<java.lang.Comparable,java.lang.Object> kvp)
java.util.List<Pair<java.lang.Comparable,java.lang.Object>>	getKeyValuePairs()
Task	merge(Task task)
void	setKeyValuePairs(java.util.List<Pair<java.lang.Comparable,java.lang.Object>> keyValuePairs)

Methods inherited from class com.cliftonsnyder.clutch.task.Task

addLengthOffsetPair, completionPercentage, getLength, getLengthOffsetPairs, getMissingLengthOffsetPairs, getTotalLength, mergeLengthOffsetPairs, setLengthOffsetPairs, setTotalLength

Methods inherited from class java.lang.Object

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

Field Detail

keyValuePairs

protected java.util.List<Pair<java.lang.Comparable,java.lang.Object>> keyValuePairs

Constructor Detail

MRTask

public MRTask()

Method Detail

addKeyValuePair

public void addKeyValuePair(Pair<java.lang.Comparable,java.lang.Object> kvp)

getKeyValuePairs

public java.util.List<Pair<java.lang.Comparable,java.lang.Object>> getKeyValuePairs()

merge

public Task merge(Task task)

Specified by:

merge in class Task

setKeyValuePairs

public void setKeyValuePairs(java.util.List<Pair<java.lang.Comparable,java.lang.Object>> keyValuePairs)