public class DDLTask extends Task<DDLWork> implements java.io.Serializable
Task.FeedType
BACKUP_COMMON_JOIN, backupChildrenTasks, backupTask, childTasks, clonedConf, COMMON_JOIN, 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 |
---|
DDLTask() |
Modifier and Type | Method and Description |
---|---|
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 ctx) |
boolean |
requireLock() |
int |
showColumns(Hive db,
ShowColumnsDesc showCols) |
static void |
writeGrantInfo(java.io.DataOutput outStream,
PrincipalType principalType,
java.lang.String principalName,
java.lang.String dbName,
java.lang.String tableName,
java.lang.String partName,
java.lang.String columnName,
PrivilegeGrantInfo grantInfo) |
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
public boolean requireLock()
requireLock
in class Task<DDLWork>
public void initialize(HiveConf conf, QueryPlan queryPlan, DriverContext ctx)
initialize
in class Task<DDLWork>
public int execute(DriverContext driverContext)
Task
public int showColumns(Hive db, ShowColumnsDesc showCols) throws HiveException
HiveException
public static void writeGrantInfo(java.io.DataOutput outStream, PrincipalType principalType, java.lang.String principalName, java.lang.String dbName, java.lang.String tableName, java.lang.String partName, java.lang.String columnName, PrivilegeGrantInfo grantInfo) throws java.io.IOException
java.io.IOException
public StageType getType()
Task
Copyright © 2012 The Apache Software Foundation