org.apache.hama.bsp
Class BSPTask
java.lang.Object
org.apache.hama.bsp.Task
org.apache.hama.bsp.BSPTask
- All Implemented Interfaces:
- org.apache.hadoop.io.Writable
public class BSPTask
- extends Task
Base class for tasks.
Field Summary |
static org.apache.commons.logging.Log |
LOG
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
LOG
public static final org.apache.commons.logging.Log LOG
BSPTask
public BSPTask()
BSPTask
public BSPTask(BSPJobID jobId,
java.lang.String jobFile,
TaskAttemptID taskid,
int partition)
createRunner
public BSPTaskRunner createRunner(GroomServer groom)
- Specified by:
createRunner
in class Task
run
public void run(BSPJob job,
BSPPeerProtocol umbilical)
throws java.io.IOException
- Description copied from class:
Task
- Run this task as a part of the named job. This method is executed in the
child process.
- Specified by:
run
in class Task
umbilical
- for progress reports
- Throws:
java.io.IOException
getConf
public BSPJob getConf()
- Specified by:
getConf
in class Task
setConf
public void setConf(BSPJob conf)
- Specified by:
setConf
in class Task
Copyright © 2008-2011 The Apache Software Foundation. All Rights Reserved.