|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.mapred.TaskController
public abstract class TaskController
Controls initialization, finalization and clean up of tasks, and
also the launching and killing of task JVMs.
This class defines the API for initializing, finalizing and cleaning
up of tasks, as also the launching and killing task JVMs.
Subclasses of this class will implement the logic required for
performing the actual actions.
NOTE: This class is internal only class and not intended for users!!
Nested Class Summary | |
---|---|
static class |
TaskController.DistributedCacheFileContext
This is used for initializing the private localized files in distributed cache. |
static class |
TaskController.InitializationContext
NOTE: This class is internal only class and not intended for users!! |
Field Summary | |
---|---|
static org.apache.commons.logging.Log |
LOG
|
protected String[] |
mapredLocalDirs
|
Constructor Summary | |
---|---|
TaskController()
|
Method Summary | |
---|---|
Configuration |
getConf()
Return the configuration used by this object. |
abstract void |
initializeDistributedCacheFile(TaskController.DistributedCacheFileContext context)
Take task-controller specific actions to initialize the distributed cache file. |
abstract void |
initializeUser(TaskController.InitializationContext context)
Initialize user on this TaskTracer in a TaskController specific manner. |
void |
setConf(Configuration conf)
Set the configuration to be used by this object. |
void |
setup()
Sets up the permissions of the following directories on all the configured disks: mapred-local directories Hadoop log directories |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final org.apache.commons.logging.Log LOG
protected String[] mapredLocalDirs
Constructor Detail |
---|
public TaskController()
Method Detail |
---|
public Configuration getConf()
Configurable
getConf
in interface Configurable
public void setConf(Configuration conf)
Configurable
setConf
in interface Configurable
public void setup() throws IOException
IOException
public abstract void initializeDistributedCacheFile(TaskController.DistributedCacheFileContext context) throws IOException
context
-
IOException
public abstract void initializeUser(TaskController.InitializationContext context) throws IOException
context
-
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |