public class ExplainTask extends Task<ExplainWork> implements java.io.Serializable
Modifier and Type | Class and Description |
---|---|
class |
ExplainTask.MethodComparator
MethodComparator.
|
Task.FeedType
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
EXPL_COLUMN_NAME |
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 |
---|
ExplainTask() |
Modifier and Type | Method and Description |
---|---|
int |
execute(DriverContext driverContext)
This method is overridden in each Task.
|
JSONObject |
getJSONLogicalPlan(java.io.PrintStream out,
ExplainWork work) |
JSONObject |
getJSONPlan(java.io.PrintStream out,
ExplainWork work) |
java.lang.String |
getName()
Gets the name of the node.
|
java.util.List<FieldSchema> |
getResultSchema() |
StageType |
getType()
Should be overridden to return the type of the specific task among the types in StageType.
|
java.lang.String |
outputAST(java.lang.String treeString,
java.io.PrintStream out,
boolean jsonOutput,
int indent) |
JSONObject |
outputDependencies(java.io.PrintStream out,
boolean jsonOutput,
java.util.List<Task<? extends java.io.Serializable>> rootTasks,
int indent) |
JSONObject |
outputStagePlans(java.io.PrintStream out,
ExplainWork work,
java.util.List<Task<? extends java.io.Serializable>> rootTasks,
int indent) |
addDependentTask, cloneConf, done, executeTask, fetch, getAndInitBackupTask, getBackupChildrenTasks, getBackupTask, getChildren, getChildTasks, getCounters, getDependentTasks, getFeedSubscribers, getId, getInitialized, getJobID, getParentTasks, getQueryPlan, getQueued, getReducer, getTaskHandle, getTaskTag, getTopOperators, getWork, hasReduce, ifRetryCmdWhenFail, initialize, isLocalMode, isMapRedLocalTask, isMapRedTask, isRunnable, pushFeed, receiveFeed, removeDependentTask, removeFromChildrenTasks, requireLock, setBackupChildrenTasks, setBackupTask, setChildTasks, setDone, setFeedSubscribers, setId, setInitialized, setLocalMode, setParentTasks, setQueryPlan, setQueued, setRetryCmdWhenFail, setStarted, setTaskTag, setWork, shutdown, started, subscribeFeed
public static final java.lang.String EXPL_COLUMN_NAME
public JSONObject getJSONLogicalPlan(java.io.PrintStream out, ExplainWork work) throws java.lang.Exception
java.lang.Exception
public JSONObject getJSONPlan(java.io.PrintStream out, ExplainWork work) throws java.lang.Exception
java.lang.Exception
public int execute(DriverContext driverContext)
Task
execute
in class Task<ExplainWork>
public java.lang.String outputAST(java.lang.String treeString, java.io.PrintStream out, boolean jsonOutput, int indent) throws JSONException
JSONException
public JSONObject outputDependencies(java.io.PrintStream out, boolean jsonOutput, java.util.List<Task<? extends java.io.Serializable>> rootTasks, int indent) throws java.lang.Exception
java.lang.Exception
public JSONObject outputStagePlans(java.io.PrintStream out, ExplainWork work, java.util.List<Task<? extends java.io.Serializable>> rootTasks, int indent) throws java.lang.Exception
java.lang.Exception
public StageType getType()
Task
getType
in class Task<ExplainWork>
public java.lang.String getName()
Node
public java.util.List<FieldSchema> getResultSchema()
getResultSchema
in class Task<ExplainWork>
Copyright © 2012 The Apache Software Foundation