public class LocalContainerLauncher extends org.apache.hadoop.service.AbstractService implements ContainerLauncher
ContainerLauncher.EventType
Constructor and Description |
---|
LocalContainerLauncher(AppContext context,
org.apache.hadoop.mapred.TaskUmbilicalProtocol umbilical) |
Modifier and Type | Method and Description |
---|---|
void |
handle(ContainerLauncherEvent event) |
protected static org.apache.hadoop.mapred.MapOutputFile |
renameMapOutputForReduce(org.apache.hadoop.mapred.JobConf conf,
org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId mapId,
org.apache.hadoop.mapred.MapOutputFile subMapOutputFile)
Within the _local_ filesystem (not HDFS), all activity takes place within
a subdir inside one of the LOCAL_DIRS
(${local.dir}/usercache/$user/appcache/$appId/$contId/),
and all sub-MapTasks create the same filename ("file.out").
|
void |
serviceStart() |
void |
serviceStop() |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceInit, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public LocalContainerLauncher(AppContext context, org.apache.hadoop.mapred.TaskUmbilicalProtocol umbilical)
public void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.AbstractService
Exception
public void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.AbstractService
Exception
public void handle(ContainerLauncherEvent event)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<ContainerLauncherEvent>
protected static org.apache.hadoop.mapred.MapOutputFile renameMapOutputForReduce(org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId mapId, org.apache.hadoop.mapred.MapOutputFile subMapOutputFile) throws IOException
IOException
Copyright © 2018 Apache Software Foundation. All Rights Reserved.