public class MapRedTask extends ExecDriver implements java.io.Serializable
Task.FeedType
job, jobExecHelper, LOG, 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 |
---|
MapRedTask() |
MapRedTask(MapredWork plan,
JobConf job,
boolean isSilent) |
Modifier and Type | Method and Description |
---|---|
int |
execute(DriverContext driverContext)
Execute a query plan using Hadoop.
|
Operator<? extends OperatorDesc> |
getReducer() |
static java.lang.String |
isEligibleForLocalMode(HiveConf conf,
int numReducers,
long inputLength,
long inputFileCount)
Find out if a job can be run in local mode based on it's characteristics
|
boolean |
mapDone() |
boolean |
mapStarted() |
boolean |
reduceDone() |
boolean |
reduceStarted() |
void |
shutdown() |
checkFatalErrors, generateCmdLine, getName, getTopOperators, getType, hasReduce, initialize, isMapRedTask, logPlanProgress, main, requireLock, setInputAttributes, updateCounters
addDependentTask, cloneConf, done, executeTask, fetch, getAndInitBackupTask, getBackupChildrenTasks, getBackupTask, getChildren, getChildTasks, getCounters, getDependentTasks, getFeedSubscribers, getId, getInitialized, getJobID, getParentTasks, getQueryPlan, getQueued, getResultSchema, getTaskHandle, getTaskTag, getWork, ifRetryCmdWhenFail, isLocalMode, isMapRedLocalTask, isRunnable, pushFeed, receiveFeed, removeDependentTask, removeFromChildrenTasks, setBackupChildrenTasks, setBackupTask, setChildTasks, setDone, setFeedSubscribers, setId, setInitialized, setLocalMode, setParentTasks, setQueryPlan, setQueued, setRetryCmdWhenFail, setStarted, setTaskTag, setWork, started, subscribeFeed
public MapRedTask()
public MapRedTask(MapredWork plan, JobConf job, boolean isSilent) throws HiveException
HiveException
public int execute(DriverContext driverContext)
ExecDriver
execute
in class ExecDriver
public boolean mapStarted()
mapStarted
in class ExecDriver
public boolean reduceStarted()
reduceStarted
in class ExecDriver
public boolean mapDone()
mapDone
in class ExecDriver
public boolean reduceDone()
reduceDone
in class ExecDriver
public static java.lang.String isEligibleForLocalMode(HiveConf conf, int numReducers, long inputLength, long inputFileCount)
conf
- Hive ConfigurationnumReducers
- total number of reducers for this jobinputLength
- the size of the inputinputFileCount
- the number of files of inputpublic Operator<? extends OperatorDesc> getReducer()
getReducer
in class Task<MapredWork>
public void shutdown()
shutdown
in class ExecDriver
Copyright © 2012 The Apache Software Foundation