public class DDLTask extends Task<DDLWork> implements Serializable
Task.FeedType, Task.TaskState
Modifier and Type | Field and Description |
---|---|
static String |
DATABASE_PATH_SUFFIX
Make qualified location for a database .
|
BACKUP_COMMON_JOIN, backupChildrenTasks, backupTask, childTasks, clonedConf, COMMON_JOIN, conf, console, CONVERTED_MAPJOIN, CONVERTED_MAPJOIN_LOCAL, CONVERTED_SORTMERGEJOIN, driverContext, feedSubscribers, HINTED_MAPJOIN, HINTED_MAPJOIN_LOCAL, id, jobID, MAPJOIN_ONLY_NOBACKUP, NO_TAG, parentTasks, queryDisplay, queryPlan, queryState, rootTask, taskCounters, taskHandle, taskTag, work
Constructor and Description |
---|
DDLTask() |
Modifier and Type | Method and Description |
---|---|
static boolean |
doesTableNeedLocation(Table tbl) |
static void |
dumpLockInfo(DataOutputStream os,
ShowLocksResponse rsp) |
int |
execute(DriverContext driverContext)
This method is overridden in each Task.
|
String |
getName()
Gets the name of the node.
|
Task<? extends Serializable> |
getSubtask() |
StageType |
getType()
Should be overridden to return the type of the specific task among the types in StageType.
|
void |
initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
static void |
makeLocationQualified(String databaseName,
StorageDescriptor sd,
String name,
HiveConf conf)
Make location in specified sd qualified.
|
boolean |
requireLock() |
int |
showColumns(Hive db,
ShowColumnsDesc showCols) |
static void |
validateSerDe(String serdeName,
HiveConf conf)
Check if the given serde is valid.
|
addDependentTask, cloneConf, done, equals, executeTask, findLeafs, getAndInitBackupTask, getBackupChildrenTasks, getBackupTask, getChildren, getChildTasks, getCounters, getDependentTasks, getDiagnosticsMessage, getDriverContext, getExternalHandle, getFeedSubscribers, getHive, getId, getInitialized, getJobID, getMapWork, getNumChild, getNumParent, getParentTasks, getQueryPlan, getQueued, getReducer, getStatusMessage, getTaskHandle, getTaskState, getTaskTag, getTopOperators, getWork, hashCode, hasReduce, ifRetryCmdWhenFail, isFetchSource, isLocalMode, isMapRedLocalTask, isMapRedTask, isRootTask, isRunnable, pushFeed, receiveFeed, removeDependentTask, removeFromChildrenTasks, setBackupChildrenTasks, setBackupTask, setChildTasks, setConsole, setDiagnosticMessage, setDone, setDriverContext, setException, setFeedSubscribers, setFetchSource, setId, setInitialized, setLocalMode, setParentTasks, setQueryDisplay, setQueryPlan, setQueued, setRetryCmdWhenFail, setRootTask, setStarted, setState, setStatusMessage, setTaskTag, setWork, shutdown, started, subscribeFeed, toString, updateStatusInQueryDisplay, updateTaskMetrics
public static final String DATABASE_PATH_SUFFIX
public Task<? extends Serializable> getSubtask()
public boolean requireLock()
requireLock
in class Task<DDLWork>
public void initialize(QueryState queryState, QueryPlan queryPlan, DriverContext ctx, CompilationOpContext opContext)
initialize
in class Task<DDLWork>
public int execute(DriverContext driverContext)
Task
public int showColumns(Hive db, ShowColumnsDesc showCols) throws HiveException
HiveException
public static void dumpLockInfo(DataOutputStream os, ShowLocksResponse rsp) throws IOException
IOException
public static void validateSerDe(String serdeName, HiveConf conf) throws HiveException
HiveException
public StageType getType()
Task
public String getName()
Node
public static void makeLocationQualified(String databaseName, StorageDescriptor sd, String name, HiveConf conf) throws HiveException
databaseName
- Database name.sd
- Storage descriptor.name
- Object name.HiveException
public static boolean doesTableNeedLocation(Table tbl)
Copyright © 2021 The Apache Software Foundation. All rights reserved.