public class MapredLocalTask extends Task<MapredLocalWork> implements java.io.Serializable
Task.FeedType
Modifier and Type | Field and Description |
---|---|
protected HadoopJobExecHelper |
jobExecHelper |
static org.apache.commons.logging.Log |
l4j |
static java.lang.management.MemoryMXBean |
memoryMXBean |
BACKUP_COMMON_JOIN, backupChildrenTasks, backupTask, childTasks, clonedConf, COMMON_JOIN, conf, console, CONVERTED_LOCAL_MAPJOIN, CONVERTED_MAPJOIN, CONVERTED_SORTMERGEJOIN, db, driverContext, feedSubscribers, id, initialized, isdone, jobID, LOCAL_MAPJOIN, MAPJOIN_ONLY_NOBACKUP, NO_TAG, parentTasks, queryPlan, queued, started, taskCounters, taskHandle, taskTag, work
Constructor and Description |
---|
MapredLocalTask() |
MapredLocalTask(MapredLocalWork plan,
JobConf job,
boolean isSilent) |
Modifier and Type | Method and Description |
---|---|
int |
execute(DriverContext driverContext)
This method is overridden in each Task.
|
int |
executeFromChildJVM(DriverContext driverContext) |
java.lang.String |
getName()
Gets the name of the node.
|
java.util.Collection<Operator<? extends OperatorDesc>> |
getTopOperators() |
StageType |
getType()
Should be overridden to return the type of the specific task among the types in StageType.
|
void |
initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext) |
boolean |
isMapRedLocalTask() |
static java.lang.String |
now() |
boolean |
requireLock() |
void |
shutdown() |
addDependentTask, cloneConf, done, executeTask, fetch, getAndInitBackupTask, getBackupChildrenTasks, getBackupTask, getChildren, getChildTasks, getCounters, getDependentTasks, getFeedSubscribers, getId, getInitialized, getJobID, getParentTasks, getQueryPlan, getQueued, getReducer, getResultSchema, getTaskHandle, getTaskTag, getWork, hasReduce, ifRetryCmdWhenFail, isLocalMode, isMapRedTask, isRunnable, pushFeed, receiveFeed, removeDependentTask, removeFromChildrenTasks, setBackupChildrenTasks, setBackupTask, setChildTasks, setDone, setFeedSubscribers, setId, setInitialized, setLocalMode, setParentTasks, setQueryPlan, setQueued, setRetryCmdWhenFail, setStarted, setTaskTag, setWork, started, subscribeFeed
protected HadoopJobExecHelper jobExecHelper
public static final transient org.apache.commons.logging.Log l4j
public static java.lang.management.MemoryMXBean memoryMXBean
public MapredLocalTask()
public MapredLocalTask(MapredLocalWork plan, JobConf job, boolean isSilent) throws HiveException
HiveException
public void initialize(HiveConf conf, QueryPlan queryPlan, DriverContext driverContext)
initialize
in class Task<MapredLocalWork>
public static java.lang.String now()
public boolean requireLock()
requireLock
in class Task<MapredLocalWork>
public int execute(DriverContext driverContext)
Task
execute
in class Task<MapredLocalWork>
public int executeFromChildJVM(DriverContext driverContext)
public boolean isMapRedLocalTask()
isMapRedLocalTask
in class Task<MapredLocalWork>
public java.util.Collection<Operator<? extends OperatorDesc>> getTopOperators()
getTopOperators
in class Task<MapredLocalWork>
public java.lang.String getName()
Node
public StageType getType()
Task
getType
in class Task<MapredLocalWork>
public void shutdown()
shutdown
in class Task<MapredLocalWork>
Copyright © 2012 The Apache Software Foundation