com.cliftonsnyder.clutch.mr.task
Class AbstractMapTaskFactory

java.lang.Object
  com.cliftonsnyder.clutch.mr.task.AbstractMapTaskFactory

All Implemented Interfaces:

MapTaskFactory, java.io.Serializable

public abstract class AbstractMapTaskFactory
extends java.lang.Object
implements MapTaskFactory

An abstraction that handles the "messy" business of migrating MapTasks

Author:

Clifton L. Snyder

See Also:

Serialized Form

Field Summary

protected ClutchState

state

Constructor Summary

AbstractMapTaskFactory()

Method Summary

MapTask	getMapTask(java.lang.String requestId)
MapTask	getMapTask(java.lang.String requestId, long offset, long length)
void	init()
void	putMapTask(MapTask task)
void	setState(ClutchState state)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.cliftonsnyder.clutch.mr.task.MapTaskFactory

createMapTask, createMapTask

Field Detail

state

protected ClutchState state

Constructor Detail

AbstractMapTaskFactory

public AbstractMapTaskFactory()

Method Detail

getMapTask

public MapTask getMapTask(java.lang.String requestId)
                   throws java.io.IOException

Specified by:

getMapTask in interface MapTaskFactory

Throws:

java.io.IOException

getMapTask

public MapTask getMapTask(java.lang.String requestId,
                          long offset,
                          long length)
                   throws java.io.IOException

Specified by:

getMapTask in interface MapTaskFactory

Throws:

java.io.IOException

setState

public void setState(ClutchState state)

Specified by:

setState in interface MapTaskFactory

putMapTask

public void putMapTask(MapTask task)

Specified by:

putMapTask in interface MapTaskFactory

init

public void init()

Specified by:

init in interface MapTaskFactory

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object