public class ColumnTruncateTask extends Task<ColumnTruncateWork> implements java.io.Serializable, HadoopJobExecHook
Task.FeedType
Modifier and Type | Field and Description |
---|---|
protected JobConf |
job |
protected HadoopJobExecHelper |
jobExecHelper |
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, LOG, MAPJOIN_ONLY_NOBACKUP, NO_TAG, parentTasks, queryPlan, queued, started, taskCounters, taskHandle, taskTag, work
Constructor and Description |
---|
ColumnTruncateTask() |
Modifier and Type | Method and Description |
---|---|
boolean |
checkFatalErrors(Counters ctrs,
java.lang.StringBuilder errMsg) |
int |
execute(DriverContext driverContext)
This method is overridden in each Task.
|
java.lang.String |
getName()
Gets the name of the node.
|
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) |
void |
logPlanProgress(SessionState ss) |
boolean |
requireLock() |
void |
updateCounters(Counters ctrs,
RunningJob rj) |
addDependentTask, cloneConf, done, executeTask, fetch, getAndInitBackupTask, getBackupChildrenTasks, getBackupTask, getChildren, getChildTasks, getCounters, getDependentTasks, getFeedSubscribers, getId, getInitialized, getJobID, getParentTasks, getQueryPlan, getQueued, getReducer, getResultSchema, getTaskHandle, getTaskTag, getTopOperators, getWork, hasReduce, ifRetryCmdWhenFail, isLocalMode, isMapRedLocalTask, isMapRedTask, isRunnable, pushFeed, receiveFeed, removeDependentTask, removeFromChildrenTasks, setBackupChildrenTasks, setBackupTask, setChildTasks, setDone, setFeedSubscribers, setId, setInitialized, setLocalMode, setParentTasks, setQueryPlan, setQueued, setRetryCmdWhenFail, setStarted, setTaskTag, setWork, shutdown, started, subscribeFeed
protected transient JobConf job
protected HadoopJobExecHelper jobExecHelper
public void initialize(HiveConf conf, QueryPlan queryPlan, DriverContext driverContext)
initialize
in class Task<ColumnTruncateWork>
public boolean requireLock()
requireLock
in class Task<ColumnTruncateWork>
public int execute(DriverContext driverContext)
Task
execute
in class Task<ColumnTruncateWork>
public java.lang.String getName()
Node
public StageType getType()
Task
getType
in class Task<ColumnTruncateWork>
public boolean checkFatalErrors(Counters ctrs, java.lang.StringBuilder errMsg)
checkFatalErrors
in interface HadoopJobExecHook
public void logPlanProgress(SessionState ss) throws java.io.IOException
logPlanProgress
in interface HadoopJobExecHook
java.io.IOException
public void updateCounters(Counters ctrs, RunningJob rj) throws java.io.IOException
updateCounters
in interface HadoopJobExecHook
java.io.IOException
Copyright © 2012 The Apache Software Foundation