Uses of Class
org.apache.hadoop.hive.ql.exec.Task

Packages that use Task

Package	Description
org.apache.hadoop.hive.hbase	Implements an HBase storage handler for Hive.
org.apache.hadoop.hive.ql
org.apache.hadoop.hive.ql.exec	Hive QL execution tasks, operators, functions and other handlers.
org.apache.hadoop.hive.ql.exec.mr
org.apache.hadoop.hive.ql.exec.spark
org.apache.hadoop.hive.ql.exec.tez
org.apache.hadoop.hive.ql.history
org.apache.hadoop.hive.ql.index
org.apache.hadoop.hive.ql.index.bitmap
org.apache.hadoop.hive.ql.index.compact
org.apache.hadoop.hive.ql.io.merge
org.apache.hadoop.hive.ql.io.rcfile.stats
org.apache.hadoop.hive.ql.io.rcfile.truncate
org.apache.hadoop.hive.ql.optimizer
org.apache.hadoop.hive.ql.optimizer.physical
org.apache.hadoop.hive.ql.optimizer.physical.index
org.apache.hadoop.hive.ql.optimizer.spark
org.apache.hadoop.hive.ql.parse
org.apache.hadoop.hive.ql.parse.authorization
org.apache.hadoop.hive.ql.parse.spark
org.apache.hadoop.hive.ql.plan
org.apache.hadoop.hive.ql.stats
org.apache.hadoop.hive.ql.stats.fs
org.apache.hadoop.hive.ql.stats.jdbc
org.apache.hive.hcatalog.cli.SemanticAnalysis

Uses of Task in org.apache.hadoop.hive.hbase

Methods in org.apache.hadoop.hive.hbase with parameters of type Task

Modifier and Type	Method and Description
boolean	HBaseStatsAggregator.connect(org.apache.hadoop.conf.Configuration hiveconf, Task sourceTask) Does the necessary HBase initializations.

Uses of Task in org.apache.hadoop.hive.ql

Methods in org.apache.hadoop.hive.ql that return Task

Modifier and Type	Method and Description
Task<? extends Serializable>	DriverContext.getRunnable(int maxthreads)

Methods in org.apache.hadoop.hive.ql that return types with arguments of type Task

Modifier and Type	Method and Description
ArrayList<Task<? extends Serializable>>	QueryPlan.getRootTasks()

Methods in org.apache.hadoop.hive.ql with parameters of type Task

Modifier and Type	Method and Description
boolean	DriverContext.addToRunnable(Task<? extends Serializable> tsk)
static boolean	DriverContext.isLaunchable(Task<? extends Serializable> tsk) Checks if a task can be launched.
void	DriverContext.remove(Task<? extends Serializable> task)

Method parameters in org.apache.hadoop.hive.ql with type arguments of type Task

Modifier and Type	Method and Description
void	QueryPlan.setRootTasks(ArrayList<Task<? extends Serializable>> rootTasks)

Uses of Task in org.apache.hadoop.hive.ql.exec

Subclasses of Task in org.apache.hadoop.hive.ql.exec

Modifier and Type	Class and Description
class	ColumnStatsTask ColumnStatsTask implementation.
class	ColumnStatsUpdateTask ColumnStatsUpdateTask implementation.
class	ConditionalTask Conditional Task implementation.
class	CopyTask CopyTask implementation.
class	DDLTask DDLTask implementation.
class	DependencyCollectionTask DependencyCollectionTask.
class	ExplainSQRewriteTask
class	ExplainTask ExplainTask implementation.
class	FetchTask FetchTask implementation.
class	FunctionTask FunctionTask.
class	MoveTask MoveTask implementation.
class	StatsNoJobTask StatsNoJobTask is used in cases where stats collection is the only task for the given query (no parent MR or Tez job).
class	StatsTask StatsTask implementation.

Fields in org.apache.hadoop.hive.ql.exec declared as Task

Modifier and Type	Field and Description
protected Task<? extends Serializable>	Task.backupTask
protected Task<? extends Serializable>	TaskRunner.tsk

Fields in org.apache.hadoop.hive.ql.exec with type parameters of type Task

Modifier and Type	Field and Description
protected List<Task<? extends Serializable>>	Task.backupChildrenTasks
protected List<Task<? extends Serializable>>	Task.childTasks
protected List<Task<? extends Serializable>>	Task.feedSubscribers
protected List<Task<? extends Serializable>>	Task.parentTasks
Class<? extends Task<T>>	TaskFactory.TaskTuple.taskClass

Methods in org.apache.hadoop.hive.ql.exec that return Task

Modifier and Type	Method and Description
static <T extends Serializable> Task<T>	TaskFactory.get(Class<T> workClass, HiveConf conf)
static <T extends Serializable> Task<T>	TaskFactory.get(T work, HiveConf conf, Task<? extends Serializable>... tasklist)
Task<? extends Serializable>	Task.getAndInitBackupTask()
static <T extends Serializable> Task<T>	TaskFactory.getAndMakeChild(T work, HiveConf conf, Task<? extends Serializable>... tasklist)
Task<? extends Serializable>	Task.getBackupTask()
Task<? extends Serializable>	TaskRunner.getTask()

Methods in org.apache.hadoop.hive.ql.exec that return types with arguments of type Task

Modifier and Type	Method and Description
List<Task<? extends Serializable>>	Task.getBackupChildrenTasks()
List<Task<? extends Serializable>>	Task.getChildTasks()
List<Task<? extends Serializable>>	Task.getDependentTasks() The default dependent tasks are just child tasks, but different types could implement their own (e.g.
List<Task<? extends Serializable>>	ConditionalTask.getDependentTasks()
List<Task<? extends Serializable>>	Task.getFeedSubscribers()
List<Task<? extends Serializable>>	ConditionalTask.getListTasks()
List<Task<? extends Serializable>>	Task.getParentTasks()

Methods in org.apache.hadoop.hive.ql.exec with parameters of type Task

Modifier and Type	Method and Description
boolean	Task.addDependentTask(Task<? extends Serializable> dependent) Add a dependent task on the current task.
boolean	ConditionalTask.addDependentTask(Task<? extends Serializable> dependent) Add a dependent task on the current conditional task.
static <T extends Serializable> Task<T>	TaskFactory.get(T work, HiveConf conf, Task<? extends Serializable>... tasklist)
static <T extends Serializable> Task<T>	TaskFactory.getAndMakeChild(T work, HiveConf conf, Task<? extends Serializable>... tasklist)
org.json.JSONObject	ExplainTask.getJSONPlan(PrintStream out, String ast, List<Task<?>> tasks, Task<?> fetchTask, boolean jsonOutput, boolean isExtended, boolean appendTaskType)
static void	TaskFactory.makeChild(Task<?> ret, Task<? extends Serializable>... tasklist)
static void	TaskFactory.makeChild(Task<?> ret, Task<? extends Serializable>... tasklist)
void	Task.removeDependentTask(Task<? extends Serializable> dependent) Remove the dependent task.
static void	Utilities.reworkMapRedWork(Task<? extends Serializable> task, boolean reworkMapredWork, HiveConf conf) The check here is kind of not clean.
void	Task.setBackupTask(Task<? extends Serializable> backupTask)
void	Task.subscribeFeed(Task<? extends Serializable> publisher) Subscribe the feed of publisher.

Method parameters in org.apache.hadoop.hive.ql.exec with type arguments of type Task

Modifier and Type	Method and Description
org.json.JSONObject	ExplainTask.getJSONPlan(PrintStream out, String ast, List<Task<?>> tasks, Task<?> fetchTask, boolean jsonOutput, boolean isExtended, boolean appendTaskType)
static List<ExecDriver>	Utilities.getMRTasks(List<Task<? extends Serializable>> tasks)
static List<SparkTask>	Utilities.getSparkTasks(List<Task<? extends Serializable>> tasks)
static List<TezTask>	Utilities.getTezTasks(List<Task<? extends Serializable>> tasks)
static <T> void	NodeUtils.iterateTask(Collection<Task<?>> tasks, Class<T> clazz, NodeUtils.Function<T> function)
org.json.JSONObject	ExplainTask.outputDependencies(PrintStream out, boolean jsonOutput, boolean appendTaskType, List<Task> tasks)
org.json.JSONObject	ExplainTask.outputStagePlans(PrintStream out, List<Task> tasks, boolean jsonOutput, boolean isExtended)
void	Task.setBackupChildrenTasks(List<Task<? extends Serializable>> backupChildrenTasks)
void	Task.setChildTasks(List<Task<? extends Serializable>> childTasks)
void	Task.setFeedSubscribers(List<Task<? extends Serializable>> s)
void	ConditionalTask.setListTasks(List<Task<? extends Serializable>> listTasks)
void	Task.setParentTasks(List<Task<? extends Serializable>> parentTasks)

Constructors in org.apache.hadoop.hive.ql.exec with parameters of type Task

Constructor and Description
TaskRunner(Task<? extends Serializable> tsk, TaskResult result)

Constructor parameters in org.apache.hadoop.hive.ql.exec with type arguments of type Task

Constructor and Description
TaskFactory.TaskTuple(Class<T> workClass, Class<? extends Task<T>> taskClass)

Uses of Task in org.apache.hadoop.hive.ql.exec.mr

Subclasses of Task in org.apache.hadoop.hive.ql.exec.mr

Modifier and Type	Class and Description
class	ExecDriver ExecDriver is the central class in co-ordinating execution of any map-reduce task.
class	MapredLocalTask MapredLocalTask represents any local work (i.e.: client side work) that hive needs to execute.
class	MapRedTask Extension of ExecDriver: - can optionally spawn a map-reduce task from a separate jvm - will make last minute adjustments to map-reduce job parameters, viz: * estimating number of reducers * estimating whether job should run locally

Fields in org.apache.hadoop.hive.ql.exec.mr declared as Task

Modifier and Type	Field and Description
protected Task<? extends Serializable>	HadoopJobExecHelper.task

Constructors in org.apache.hadoop.hive.ql.exec.mr with parameters of type Task

Constructor and Description
HadoopJobExecHelper(org.apache.hadoop.mapred.JobConf job, SessionState.LogHelper console, Task<? extends Serializable> task, HadoopJobExecHook hookCallBack)

Uses of Task in org.apache.hadoop.hive.ql.exec.spark

Subclasses of Task in org.apache.hadoop.hive.ql.exec.spark

Modifier and Type	Class and Description
class	SparkTask

Uses of Task in org.apache.hadoop.hive.ql.exec.tez

Subclasses of Task in org.apache.hadoop.hive.ql.exec.tez

Modifier and Type	Class and Description
class	TezTask TezTask handles the execution of TezWork.

Uses of Task in org.apache.hadoop.hive.ql.history

Methods in org.apache.hadoop.hive.ql.history with parameters of type Task

Modifier and Type	Method and Description
void	HiveHistoryImpl.endTask(String queryId, Task<? extends Serializable> task)
void	HiveHistory.endTask(String queryId, Task<? extends Serializable> task) Called at the end of a task.
void	HiveHistoryImpl.progressTask(String queryId, Task<? extends Serializable> task)
void	HiveHistory.progressTask(String queryId, Task<? extends Serializable> task) Logs progress of a task if ConfVars.HIVE_LOG_INCREMENTAL_PLAN_PROGRESS is set to true
void	HiveHistoryImpl.startTask(String queryId, Task<? extends Serializable> task, String taskName)
void	HiveHistory.startTask(String queryId, Task<? extends Serializable> task, String taskName) Called at the start of a task.

Uses of Task in org.apache.hadoop.hive.ql.index

Subclasses of Task in org.apache.hadoop.hive.ql.index

Modifier and Type	Class and Description
class	IndexMetadataChangeTask

Methods in org.apache.hadoop.hive.ql.index that return Task

Modifier and Type	Method and Description
protected Task<?>	TableBasedIndexHandler.getIndexBuilderMapRedTask(Set<ReadEntity> inputs, Set<WriteEntity> outputs, Index index, boolean partitioned, PartitionDesc indexTblPartDesc, String indexTableName, PartitionDesc baseTablePartDesc, String baseTableName, String dbName)
protected Task<?>	AggregateIndexHandler.getIndexBuilderMapRedTask(Set<ReadEntity> inputs, Set<WriteEntity> outputs, Index index, boolean partitioned, PartitionDesc indexTblPartDesc, String indexTableName, PartitionDesc baseTablePartDesc, String baseTableName, String dbName)
protected Task<?>	TableBasedIndexHandler.getIndexBuilderMapRedTask(Set<ReadEntity> inputs, Set<WriteEntity> outputs, List<FieldSchema> indexField, boolean partitioned, PartitionDesc indexTblPartDesc, String indexTableName, PartitionDesc baseTablePartDesc, String baseTableName, String dbName)

Methods in org.apache.hadoop.hive.ql.index that return types with arguments of type Task

Modifier and Type	Method and Description
List<Task<?>>	TableBasedIndexHandler.generateIndexBuildTaskList(Table baseTbl, Index index, List<Partition> indexTblPartitions, List<Partition> baseTblPartitions, Table indexTbl, Set<ReadEntity> inputs, Set<WriteEntity> outputs)
List<Task<?>>	HiveIndexHandler.generateIndexBuildTaskList(Table baseTbl, Index index, List<Partition> indexTblPartitions, List<Partition> baseTblPartitions, Table indexTbl, Set<ReadEntity> inputs, Set<WriteEntity> outputs) Requests that the handler generate a plan for building the index; the plan should read the base table and write out the index representation.
List<Task<? extends Serializable>>	HiveIndexQueryContext.getQueryTasks()

Method parameters in org.apache.hadoop.hive.ql.index with type arguments of type Task

Modifier and Type	Method and Description
void	HiveIndexQueryContext.setQueryTasks(List<Task<? extends Serializable>> indexQueryTasks)

Uses of Task in org.apache.hadoop.hive.ql.index.bitmap

Methods in org.apache.hadoop.hive.ql.index.bitmap that return Task

Modifier and Type	Method and Description
protected Task<?>	BitmapIndexHandler.getIndexBuilderMapRedTask(Set<ReadEntity> inputs, Set<WriteEntity> outputs, List<FieldSchema> indexField, boolean partitioned, PartitionDesc indexTblPartDesc, String indexTableName, PartitionDesc baseTablePartDesc, String baseTableName, String dbName)

Uses of Task in org.apache.hadoop.hive.ql.index.compact

Methods in org.apache.hadoop.hive.ql.index.compact that return Task

Modifier and Type	Method and Description
protected Task<?>	CompactIndexHandler.getIndexBuilderMapRedTask(Set<ReadEntity> inputs, Set<WriteEntity> outputs, List<FieldSchema> indexField, boolean partitioned, PartitionDesc indexTblPartDesc, String indexTableName, PartitionDesc baseTablePartDesc, String baseTableName, String dbName)

Uses of Task in org.apache.hadoop.hive.ql.io.merge

Subclasses of Task in org.apache.hadoop.hive.ql.io.merge

Modifier and Type	Class and Description
class	MergeFileTask Task for fast merging of ORC and RC files.

Uses of Task in org.apache.hadoop.hive.ql.io.rcfile.stats

Subclasses of Task in org.apache.hadoop.hive.ql.io.rcfile.stats

Modifier and Type	Class and Description
class	PartialScanTask PartialScanTask.

Uses of Task in org.apache.hadoop.hive.ql.io.rcfile.truncate

Subclasses of Task in org.apache.hadoop.hive.ql.io.rcfile.truncate

Modifier and Type	Class and Description
class	ColumnTruncateTask

Uses of Task in org.apache.hadoop.hive.ql.optimizer

Methods in org.apache.hadoop.hive.ql.optimizer that return Task

Modifier and Type	Method and Description
static Task<?>	IndexUtils.createRootTask(HiveConf builderConf, Set<ReadEntity> inputs, Set<WriteEntity> outputs, StringBuilder command, LinkedHashMap<String,String> partSpec, String indexTableName, String dbName)
static Task<MoveWork>	GenMapRedUtils.findMoveTask(List<Task<MoveWork>> mvTasks, FileSinkOperator fsOp)
Task<? extends Serializable>	GenMRProcContext.getCurrTask()
Task<? extends Serializable>	GenMRProcContext.GenMapRedCtx.getCurrTask()
Task<? extends Serializable>	GenMRProcContext.GenMRUnionCtx.getUTask()

Methods in org.apache.hadoop.hive.ql.optimizer that return types with arguments of type Task

Modifier and Type	Method and Description
Map<FileSinkDesc,Task<? extends Serializable>>	GenMRProcContext.getLinkedFileDescTasks()
List<Task<MoveWork>>	GenMRProcContext.getMvTask()
HashMap<Operator<? extends OperatorDesc>,Task<? extends Serializable>>	GenMRProcContext.getOpTaskMap()
List<Task<? extends Serializable>>	GenMRProcContext.getRootTasks()

Methods in org.apache.hadoop.hive.ql.optimizer with parameters of type Task

Modifier and Type	Method and Description
static void	GenMapRedUtils.addDependentMoveTasks(Task<MoveWork> mvTask, HiveConf hconf, Task<? extends Serializable> parentTask, DependencyCollectionTask dependencyTask) Adds the dependencyTaskForMultiInsert in ctx as a dependent of parentTask.
static void	GenMapRedUtils.addDependentMoveTasks(Task<MoveWork> mvTask, HiveConf hconf, Task<? extends Serializable> parentTask, DependencyCollectionTask dependencyTask) Adds the dependencyTaskForMultiInsert in ctx as a dependent of parentTask.
boolean	GenMRProcContext.addRootIfPossible(Task<? extends Serializable> task)
void	GenMRProcContext.addSeenOp(Task task, Operator operator)
static void	GenMapRedUtils.addStatsTask(FileSinkOperator nd, MoveTask mvTask, Task<? extends Serializable> currTask, HiveConf hconf) Add the StatsTask as a dependent task of the MoveTask because StatsTask will change the Table/Partition metadata.
static ConditionalTask	GenMapRedUtils.createCondTask(HiveConf conf, Task<? extends Serializable> currTask, MoveWork mvWork, Serializable mergeWork, String inputPath) Construct a conditional task given the current leaf task, the MoveWork and the MapredWork.
static org.apache.hadoop.fs.Path	GenMapRedUtils.createMoveTask(Task<? extends Serializable> currTask, boolean chDir, FileSinkOperator fsOp, ParseContext parseCtx, List<Task<MoveWork>> mvTasks, HiveConf hconf, DependencyCollectionTask dependencyTask) Create and add any dependent move tasks
static void	GenMapRedUtils.createMRWorkForMergingFiles(FileSinkOperator fsInput, org.apache.hadoop.fs.Path finalName, DependencyCollectionTask dependencyTask, List<Task<MoveWork>> mvTasks, HiveConf conf, Task<? extends Serializable> currTask)
static void	GenMapRedUtils.initUnionPlan(GenMRProcContext opProcCtx, UnionOperator currUnionOp, Task<? extends Serializable> currTask, boolean local)
static void	GenMapRedUtils.initUnionPlan(ReduceSinkOperator op, UnionOperator currUnionOp, GenMRProcContext opProcCtx, Task<? extends Serializable> unionTask) Initialize the current union plan.
static void	GenMapRedUtils.internTableDesc(Task<?> task, com.google.common.collect.Interner<TableDesc> interner)
static boolean	GenMapRedUtils.isMergeRequired(List<Task<MoveWork>> mvTasks, HiveConf hconf, FileSinkOperator fsOp, Task<? extends Serializable> currTask, boolean isInsertTable) Returns true iff the fsOp requires a merge
boolean	GenMRProcContext.isSeenOp(Task task, Operator operator)
static void	GenMapRedUtils.joinPlan(Task<? extends Serializable> currTask, Task<? extends Serializable> oldTask, GenMRProcContext opProcCtx) Merge the current task into the old task for the reducer
static void	GenMapRedUtils.joinPlan(Task<? extends Serializable> currTask, Task<? extends Serializable> oldTask, GenMRProcContext opProcCtx) Merge the current task into the old task for the reducer
static void	GenMapRedUtils.joinUnionPlan(GenMRProcContext opProcCtx, UnionOperator currUnionOp, Task<? extends Serializable> currentUnionTask, Task<? extends Serializable> existingTask, boolean local)
static void	GenMapRedUtils.joinUnionPlan(GenMRProcContext opProcCtx, UnionOperator currUnionOp, Task<? extends Serializable> currentUnionTask, Task<? extends Serializable> existingTask, boolean local)
static void	GenMapRedUtils.linkMoveTask(Task<MoveWork> mvTask, Task<? extends Serializable> task, HiveConf hconf, DependencyCollectionTask dependencyTask) Follows the task tree down from task and makes all leaves parents of mvTask
static void	GenMapRedUtils.linkMoveTask(Task<MoveWork> mvTask, Task<? extends Serializable> task, HiveConf hconf, DependencyCollectionTask dependencyTask) Follows the task tree down from task and makes all leaves parents of mvTask
void	GenMRProcContext.setCurrTask(Task<? extends Serializable> currTask)
static void	GenMapRedUtils.setKeyAndValueDescForTaskTree(Task<? extends Serializable> task) Set the key and value description for all the tasks rooted at the given task.
static void	GenMapRedUtils.setTaskPlan(String alias_id, Operator<? extends OperatorDesc> topOp, Task<?> task, boolean local, GenMRProcContext opProcCtx) set the current task in the mapredWork.
static void	GenMapRedUtils.setTaskPlan(String alias_id, Operator<? extends OperatorDesc> topOp, Task<?> task, boolean local, GenMRProcContext opProcCtx, PrunedPartitionList pList) set the current task in the mapredWork.

Method parameters in org.apache.hadoop.hive.ql.optimizer with type arguments of type Task

Modifier and Type	Method and Description
static org.apache.hadoop.fs.Path	GenMapRedUtils.createMoveTask(Task<? extends Serializable> currTask, boolean chDir, FileSinkOperator fsOp, ParseContext parseCtx, List<Task<MoveWork>> mvTasks, HiveConf hconf, DependencyCollectionTask dependencyTask) Create and add any dependent move tasks
static void	GenMapRedUtils.createMRWorkForMergingFiles(FileSinkOperator fsInput, org.apache.hadoop.fs.Path finalName, DependencyCollectionTask dependencyTask, List<Task<MoveWork>> mvTasks, HiveConf conf, Task<? extends Serializable> currTask)
static Task<MoveWork>	GenMapRedUtils.findMoveTask(List<Task<MoveWork>> mvTasks, FileSinkOperator fsOp)
static boolean	GenMapRedUtils.isMergeRequired(List<Task<MoveWork>> mvTasks, HiveConf hconf, FileSinkOperator fsOp, Task<? extends Serializable> currTask, boolean isInsertTable) Returns true iff the fsOp requires a merge
static void	GenMapRedUtils.linkMoveTask(FileSinkOperator newOutput, ConditionalTask cndTsk, List<Task<MoveWork>> mvTasks, HiveConf hconf, DependencyCollectionTask dependencyTask) Make the move task in the GenMRProcContext following the FileSinkOperator a dependent of all possible subtrees branching from the ConditionalTask.
void	GenMRProcContext.setLinkedFileDescTasks(Map<FileSinkDesc,Task<? extends Serializable>> linkedFileDescTasks)
void	GenMRProcContext.setMvTask(List<Task<MoveWork>> mvTask)
void	GenMRProcContext.setOpTaskMap(HashMap<Operator<? extends OperatorDesc>,Task<? extends Serializable>> opTaskMap)
void	GenMRProcContext.setRootTasks(List<Task<? extends Serializable>> rootTasks)

Constructors in org.apache.hadoop.hive.ql.optimizer with parameters of type Task

Constructor and Description
GenMRProcContext.GenMapRedCtx(Task<? extends Serializable> currTask, String currAliasId)
GenMRProcContext.GenMRUnionCtx(Task<? extends Serializable> uTask)

Constructor parameters in org.apache.hadoop.hive.ql.optimizer with type arguments of type Task

Constructor and Description
GenMRProcContext(HiveConf conf, HashMap<Operator<? extends OperatorDesc>,Task<? extends Serializable>> opTaskMap, ParseContext parseCtx, List<Task<MoveWork>> mvTask, List<Task<? extends Serializable>> rootTasks, LinkedHashMap<Operator<? extends OperatorDesc>,GenMRProcContext.GenMapRedCtx> mapCurrCtx, Set<ReadEntity> inputs, Set<WriteEntity> outputs)
GenMRProcContext(HiveConf conf, HashMap<Operator<? extends OperatorDesc>,Task<? extends Serializable>> opTaskMap, ParseContext parseCtx, List<Task<MoveWork>> mvTask, List<Task<? extends Serializable>> rootTasks, LinkedHashMap<Operator<? extends OperatorDesc>,GenMRProcContext.GenMapRedCtx> mapCurrCtx, Set<ReadEntity> inputs, Set<WriteEntity> outputs)
GenMRProcContext(HiveConf conf, HashMap<Operator<? extends OperatorDesc>,Task<? extends Serializable>> opTaskMap, ParseContext parseCtx, List<Task<MoveWork>> mvTask, List<Task<? extends Serializable>> rootTasks, LinkedHashMap<Operator<? extends OperatorDesc>,GenMRProcContext.GenMapRedCtx> mapCurrCtx, Set<ReadEntity> inputs, Set<WriteEntity> outputs)

Uses of Task in org.apache.hadoop.hive.ql.optimizer.physical

Fields in org.apache.hadoop.hive.ql.optimizer.physical declared as Task

Modifier and Type	Field and Description
protected Task<? extends Serializable>	PhysicalContext.fetchTask

Fields in org.apache.hadoop.hive.ql.optimizer.physical with type parameters of type Task

Modifier and Type	Field and Description
protected List<Task<? extends Serializable>>	PhysicalContext.rootTasks
protected Set<Task<?>>	StageIDsRearranger.TaskTraverse.traversed

Methods in org.apache.hadoop.hive.ql.optimizer.physical that return Task

Modifier and Type	Method and Description
Task<? extends Serializable>	SkewJoinResolver.SkewJoinProcCtx.getCurrentTask()
Task<? extends Serializable>	MapJoinResolver.LocalMapJoinProcCtx.getCurrentTask()
Task<? extends Serializable>	PhysicalContext.getFetchTask()
Task<? extends Serializable>	SortMergeJoinTaskDispatcher.processCurrentTask(MapRedTask currTask, ConditionalTask conditionalTask, Context context)
Task<? extends Serializable>	CommonJoinTaskDispatcher.processCurrentTask(MapRedTask currTask, ConditionalTask conditionalTask, Context context)
abstract Task<? extends Serializable>	AbstractJoinTaskDispatcher.processCurrentTask(MapRedTask currTask, ConditionalTask conditionalTask, Context context)

Methods in org.apache.hadoop.hive.ql.optimizer.physical that return types with arguments of type Task

Modifier and Type	Method and Description
protected List<Task<?>>	StageIDsRearranger.TaskTraverse.getChildTasks(Task<?> task)
static List<Task>	StageIDsRearranger.getExplainOrder(HiveConf conf, List<Task<?>> tasks)
static List<Task>	StageIDsRearranger.getFetchSources(List<Task<?>> tasks)
List<Task<? extends Serializable>>	PhysicalContext.getRootTasks()
protected List<Task<?>>	StageIDsRearranger.TaskTraverse.next(Task<?> task)

Methods in org.apache.hadoop.hive.ql.optimizer.physical with parameters of type Task

Modifier and Type	Method and Description
protected void	StageIDsRearranger.TaskTraverse.accepted(Task<?> task)
void	PhysicalContext.addToRootTask(Task<? extends Serializable> tsk)
protected List<Task<?>>	StageIDsRearranger.TaskTraverse.getChildTasks(Task<?> task)
protected boolean	StageIDsRearranger.TaskTraverse.isReady(Task<?> task)
protected List<Task<?>>	StageIDsRearranger.TaskTraverse.next(Task<?> task)
static void	GenMRSkewJoinProcessor.processSkewJoin(JoinOperator joinOp, Task<? extends Serializable> currTask, ParseContext parseCtx) Create tasks for processing skew joins.
static void	GenSparkSkewJoinProcessor.processSkewJoin(JoinOperator joinOp, Task<? extends Serializable> currTask, ReduceWork reduceWork, ParseContext parseCtx)
protected void	StageIDsRearranger.TaskTraverse.rejected(Task<?> child)
void	PhysicalContext.removeFromRootTask(Task<? extends Serializable> tsk)
protected void	AbstractJoinTaskDispatcher.replaceTask(Task<? extends Serializable> currTask, Task<? extends Serializable> newTask)
protected void	AbstractJoinTaskDispatcher.replaceTask(Task<? extends Serializable> currTask, Task<? extends Serializable> newTask)
protected void	AbstractJoinTaskDispatcher.replaceTaskWithConditionalTask(Task<? extends Serializable> currTask, ConditionalTask cndTsk)
void	SkewJoinResolver.SkewJoinProcCtx.setCurrentTask(Task<? extends Serializable> currentTask)
void	MapJoinResolver.LocalMapJoinProcCtx.setCurrentTask(Task<? extends Serializable> currentTask)
void	PhysicalContext.setFetchTask(Task<? extends Serializable> fetchTask)
void	StageIDsRearranger.TaskTraverse.traverse(Task<?> task)

Method parameters in org.apache.hadoop.hive.ql.optimizer.physical with type arguments of type Task

Modifier and Type	Method and Description
static List<Task>	StageIDsRearranger.getExplainOrder(HiveConf conf, List<Task<?>> tasks)
static List<Task>	StageIDsRearranger.getFetchSources(List<Task<?>> tasks)
void	PhysicalContext.setRootTasks(List<Task<? extends Serializable>> rootTasks)

Constructors in org.apache.hadoop.hive.ql.optimizer.physical with parameters of type Task

Constructor and Description
MapJoinResolver.LocalMapJoinProcCtx(Task<? extends Serializable> task, ParseContext parseCtx)
PhysicalContext(HiveConf conf, ParseContext parseContext, Context context, List<Task<? extends Serializable>> rootTasks, Task<? extends Serializable> fetchTask)
SkewJoinResolver.SkewJoinProcCtx(Task<? extends Serializable> task, ParseContext parseCtx)

Constructor parameters in org.apache.hadoop.hive.ql.optimizer.physical with type arguments of type Task

Constructor and Description
PhysicalContext(HiveConf conf, ParseContext parseContext, Context context, List<Task<? extends Serializable>> rootTasks, Task<? extends Serializable> fetchTask)

Uses of Task in org.apache.hadoop.hive.ql.optimizer.physical.index

Methods in org.apache.hadoop.hive.ql.optimizer.physical.index that return Task

Modifier and Type	Method and Description
Task<? extends Serializable>	IndexWhereProcCtx.getCurrentTask()

Constructors in org.apache.hadoop.hive.ql.optimizer.physical.index with parameters of type Task

Constructor and Description
IndexWhereProcCtx(Task<? extends Serializable> task, ParseContext parseCtx)

Uses of Task in org.apache.hadoop.hive.ql.optimizer.spark

Constructors in org.apache.hadoop.hive.ql.optimizer.spark with parameters of type Task

Constructor and Description
SparkSkewJoinResolver.SparkSkewJoinProcCtx(Task<? extends Serializable> task, ParseContext parseCtx)

Uses of Task in org.apache.hadoop.hive.ql.parse

Fields in org.apache.hadoop.hive.ql.parse with type parameters of type Task

Modifier and Type	Field and Description
List<Task<MoveWork>>	GenTezProcContext.moveTask
List<Task<? extends Serializable>>	GenTezProcContext.rootTasks
protected List<Task<? extends Serializable>>	BaseSemanticAnalyzer.rootTasks

Methods in org.apache.hadoop.hive.ql.parse that return types with arguments of type Task

Modifier and Type	Method and Description
List<Task<? extends Serializable>>	IndexUpdater.generateUpdateTasks()
List<Task<? extends Serializable>>	BaseSemanticAnalyzer.getRootTasks()

Methods in org.apache.hadoop.hive.ql.parse with parameters of type Task

Modifier and Type	Method and Description
void	ParseContext.replaceRootTask(Task<? extends Serializable> rootTask, List<? extends Task<? extends Serializable>> tasks)
protected void	TezCompiler.setInputFormat(Task<? extends Serializable> task)
protected abstract void	TaskCompiler.setInputFormat(Task<? extends Serializable> rootTask)
protected void	MapReduceCompiler.setInputFormat(Task<? extends Serializable> task)

Method parameters in org.apache.hadoop.hive.ql.parse with type arguments of type Task

Modifier and Type	Method and Description
void	TaskCompiler.compile(ParseContext pCtx, List<Task<? extends Serializable>> rootTasks, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
protected void	TezCompiler.decideExecMode(List<Task<? extends Serializable>> rootTasks, Context ctx, GlobalLimitCtx globalLimitCtx)
protected abstract void	TaskCompiler.decideExecMode(List<Task<? extends Serializable>> rootTasks, Context ctx, GlobalLimitCtx globalLimitCtx)
protected void	MapReduceCompiler.decideExecMode(List<Task<? extends Serializable>> rootTasks, Context ctx, GlobalLimitCtx globalLimitCtx)
protected void	TaskCompiler.genColumnStatsTask(BaseSemanticAnalyzer.AnalyzeRewriteContext analyzeRewrite, List<LoadTableDesc> loadTableWork, List<LoadFileDesc> loadFileWork, List<Task<? extends Serializable>> rootTasks, int outerQueryLimit) A helper function to generate a column stats task on top of map-red task.
protected void	TezCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, List<Task<MoveWork>> mvTask, Set<ReadEntity> inputs, Set<WriteEntity> outputs)
protected void	TezCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, List<Task<MoveWork>> mvTask, Set<ReadEntity> inputs, Set<WriteEntity> outputs)
protected abstract void	TaskCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, List<Task<MoveWork>> mvTask, Set<ReadEntity> inputs, Set<WriteEntity> outputs)
protected abstract void	TaskCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, List<Task<MoveWork>> mvTask, Set<ReadEntity> inputs, Set<WriteEntity> outputs)
protected void	MapReduceCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, List<Task<MoveWork>> mvTask, Set<ReadEntity> inputs, Set<WriteEntity> outputs)
protected void	MapReduceCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, List<Task<MoveWork>> mvTask, Set<ReadEntity> inputs, Set<WriteEntity> outputs)
protected void	TaskCompiler.getLeafTasks(List<Task<? extends Serializable>> rootTasks, HashSet<Task<? extends Serializable>> leaves) Find all leaf tasks of the list of root tasks.
protected void	TaskCompiler.getLeafTasks(List<Task<? extends Serializable>> rootTasks, HashSet<Task<? extends Serializable>> leaves) Find all leaf tasks of the list of root tasks.
ParseContext	TaskCompiler.getParseContext(ParseContext pCtx, List<Task<? extends Serializable>> rootTasks) Create a clone of the parse context
protected void	TezCompiler.optimizeTaskPlan(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, Context ctx)
protected abstract void	TaskCompiler.optimizeTaskPlan(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, Context ctx)
protected void	MapReduceCompiler.optimizeTaskPlan(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, Context ctx)
void	HiveSemanticAnalyzerHook.postAnalyze(HiveSemanticAnalyzerHookContext context, List<Task<? extends Serializable>> rootTasks) Invoked after Hive performs its own semantic analysis on a statement (including optimization).
void	AbstractSemanticAnalyzerHook.postAnalyze(HiveSemanticAnalyzerHookContext context, List<Task<? extends Serializable>> rootTasks)
void	ParseContext.replaceRootTask(Task<? extends Serializable> rootTask, List<? extends Task<? extends Serializable>> tasks)

Constructor parameters in org.apache.hadoop.hive.ql.parse with type arguments of type Task

Constructor and Description
GenTezProcContext(HiveConf conf, ParseContext parseContext, List<Task<MoveWork>> moveTask, List<Task<? extends Serializable>> rootTasks, Set<ReadEntity> inputs, Set<WriteEntity> outputs)
GenTezProcContext(HiveConf conf, ParseContext parseContext, List<Task<MoveWork>> moveTask, List<Task<? extends Serializable>> rootTasks, Set<ReadEntity> inputs, Set<WriteEntity> outputs)
ParseContext(HiveConf conf, HashMap<TableScanOperator,ExprNodeDesc> opToPartPruner, HashMap<TableScanOperator,PrunedPartitionList> opToPartList, HashMap<String,Operator<? extends OperatorDesc>> topOps, Set<JoinOperator> joinOps, Set<SMBMapJoinOperator> smbMapJoinOps, List<LoadTableDesc> loadTableWork, List<LoadFileDesc> loadFileWork, Context ctx, HashMap<String,String> idToTableNameMap, int destTableId, UnionProcContext uCtx, List<AbstractMapJoinOperator<? extends MapJoinDesc>> listMapJoinOpsNoReducer, Map<String,PrunedPartitionList> prunedPartitions, HashMap<TableScanOperator,FilterDesc.SampleDesc> opToSamplePruner, GlobalLimitCtx globalLimitCtx, HashMap<String,SplitSample> nameToSplitSample, HashSet<ReadEntity> semanticInputs, List<Task<? extends Serializable>> rootTasks, Map<TableScanOperator,Map<String,ExprNodeDesc>> opToPartToSkewedPruner, Map<String,ReadEntity> viewAliasToInput, List<ReduceSinkOperator> reduceSinkOperatorsAddedByEnforceBucketingSorting, BaseSemanticAnalyzer.AnalyzeRewriteContext analyzeRewrite, CreateTableDesc createTableDesc, QueryProperties queryProperties)

Uses of Task in org.apache.hadoop.hive.ql.parse.authorization

Methods in org.apache.hadoop.hive.ql.parse.authorization that return Task

Modifier and Type	Method and Description
Task<? extends Serializable>	HiveAuthorizationTaskFactoryImpl.createCreateRoleTask(ASTNode ast, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactory.createCreateRoleTask(ASTNode node, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactoryImpl.createDropRoleTask(ASTNode ast, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactory.createDropRoleTask(ASTNode node, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactoryImpl.createGrantRoleTask(ASTNode ast, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactory.createGrantRoleTask(ASTNode node, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactoryImpl.createGrantTask(ASTNode ast, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactory.createGrantTask(ASTNode node, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactoryImpl.createRevokeRoleTask(ASTNode ast, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactory.createRevokeRoleTask(ASTNode node, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactoryImpl.createRevokeTask(ASTNode ast, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactory.createRevokeTask(ASTNode node, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactoryImpl.createSetRoleTask(String roleName, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactory.createSetRoleTask(String roleName, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactoryImpl.createShowCurrentRoleTask(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, org.apache.hadoop.fs.Path resFile)
Task<? extends Serializable>	HiveAuthorizationTaskFactory.createShowCurrentRoleTask(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, org.apache.hadoop.fs.Path resFile)
Task<? extends Serializable>	HiveAuthorizationTaskFactoryImpl.createShowGrantTask(ASTNode ast, org.apache.hadoop.fs.Path resultFile, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactory.createShowGrantTask(ASTNode node, org.apache.hadoop.fs.Path resultFile, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactoryImpl.createShowRoleGrantTask(ASTNode ast, org.apache.hadoop.fs.Path resultFile, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactory.createShowRoleGrantTask(ASTNode node, org.apache.hadoop.fs.Path resultFile, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactoryImpl.createShowRolePrincipalsTask(ASTNode ast, org.apache.hadoop.fs.Path resFile, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactory.createShowRolePrincipalsTask(ASTNode ast, org.apache.hadoop.fs.Path resFile, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactoryImpl.createShowRolesTask(ASTNode ast, org.apache.hadoop.fs.Path resFile, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
Task<? extends Serializable>	HiveAuthorizationTaskFactory.createShowRolesTask(ASTNode ast, org.apache.hadoop.fs.Path resFile, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)

Uses of Task in org.apache.hadoop.hive.ql.parse.spark

Fields in org.apache.hadoop.hive.ql.parse.spark with type parameters of type Task

Modifier and Type	Field and Description
List<Task<MoveWork>>	GenSparkProcContext.moveTask
List<Task<? extends Serializable>>	GenSparkProcContext.rootTasks

Methods in org.apache.hadoop.hive.ql.parse.spark with parameters of type Task

Modifier and Type	Method and Description
protected void	SparkCompiler.setInputFormat(Task<? extends Serializable> task)

Method parameters in org.apache.hadoop.hive.ql.parse.spark with type arguments of type Task

Modifier and Type	Method and Description
protected void	SparkCompiler.decideExecMode(List<Task<? extends Serializable>> rootTasks, Context ctx, GlobalLimitCtx globalLimitCtx)
protected void	SparkCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, List<Task<MoveWork>> mvTask, Set<ReadEntity> inputs, Set<WriteEntity> outputs) TODO: need to turn on rules that's commented out and add more if necessary.
protected void	SparkCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, List<Task<MoveWork>> mvTask, Set<ReadEntity> inputs, Set<WriteEntity> outputs) TODO: need to turn on rules that's commented out and add more if necessary.
protected void	SparkCompiler.optimizeTaskPlan(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, Context ctx)

Constructor parameters in org.apache.hadoop.hive.ql.parse.spark with type arguments of type Task

Constructor and Description
GenSparkProcContext(HiveConf conf, ParseContext parseContext, List<Task<MoveWork>> moveTask, List<Task<? extends Serializable>> rootTasks, Set<ReadEntity> inputs, Set<WriteEntity> outputs, Map<String,Operator<? extends OperatorDesc>> topOps)
GenSparkProcContext(HiveConf conf, ParseContext parseContext, List<Task<MoveWork>> moveTask, List<Task<? extends Serializable>> rootTasks, Set<ReadEntity> inputs, Set<WriteEntity> outputs, Map<String,Operator<? extends OperatorDesc>> topOps)

Uses of Task in org.apache.hadoop.hive.ql.plan

Methods in org.apache.hadoop.hive.ql.plan that return Task

Modifier and Type	Method and Description
Task<? extends Serializable>	ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx.getCommonJoinTask()
Task<? extends Serializable>	ExplainWork.getFetchTask()
Task<? extends Serializable>	ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx.getNoSkewTask()
Task	StatsWork.getSourceTask()
protected Task<? extends Serializable>	ConditionalResolverCommonJoin.resolveMapJoinTask(ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx ctx, HiveConf conf)

Methods in org.apache.hadoop.hive.ql.plan that return types with arguments of type Task

Modifier and Type	Method and Description
HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>>	ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx.getDirToTaskMap()
List<Task<? extends Serializable>>	ConditionalResolverMergeFiles.ConditionalResolverMergeFilesCtx.getListTasks()
ArrayList<Task<? extends Serializable>>	ExplainWork.getRootTasks()
List<Task<? extends Serializable>>	ConditionalResolverSkewJoin.getTasks(HiveConf conf, Object objCtx)
List<Task<? extends Serializable>>	ConditionalResolverMergeFiles.getTasks(HiveConf conf, Object objCtx)
List<Task<? extends Serializable>>	ConditionalResolverCommonJoin.getTasks(HiveConf conf, Object objCtx)
List<Task<? extends Serializable>>	ConditionalResolver.getTasks(HiveConf conf, Object ctx) All conditional resolvers implement this interface.
HashMap<Task<? extends Serializable>,Set<String>>	ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx.getTaskToAliases()

Methods in org.apache.hadoop.hive.ql.plan with parameters of type Task

Modifier and Type	Method and Description
void	ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx.setCommonJoinTask(Task<? extends Serializable> commonJoinTask)
void	ExplainWork.setFetchTask(Task<? extends Serializable> fetchTask)
void	ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx.setNoSkewTask(Task<? extends Serializable> noSkewTask)
void	StatsWork.setSourceTask(Task sourceTask)

Method parameters in org.apache.hadoop.hive.ql.plan with type arguments of type Task

Modifier and Type	Method and Description
void	ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx.setDirToTaskMap(HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> dirToTaskMap)
void	ConditionalResolverMergeFiles.ConditionalResolverMergeFilesCtx.setListTasks(List<Task<? extends Serializable>> listTasks)
void	ExplainWork.setRootTasks(ArrayList<Task<? extends Serializable>> rootTasks)
void	ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx.setTaskToAliases(HashMap<Task<? extends Serializable>,Set<String>> taskToAliases)

Constructors in org.apache.hadoop.hive.ql.plan with parameters of type Task

Constructor and Description
ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx(HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> dirToTaskMap, Task<? extends Serializable> noSkewTask)
ExplainWork(org.apache.hadoop.fs.Path resFile, ParseContext pCtx, List<Task<? extends Serializable>> rootTasks, Task<? extends Serializable> fetchTask, String astStringTree, BaseSemanticAnalyzer analyzer, boolean extended, boolean formatted, boolean dependency, boolean logical, boolean authorize, boolean userLevelExplain, String cboInfo)

Constructor parameters in org.apache.hadoop.hive.ql.plan with type arguments of type Task

Constructor and Description
ConditionalResolverMergeFiles.ConditionalResolverMergeFilesCtx(List<Task<? extends Serializable>> listTasks, String dir)
ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx(HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> dirToTaskMap, Task<? extends Serializable> noSkewTask)
ExplainWork(org.apache.hadoop.fs.Path resFile, ParseContext pCtx, List<Task<? extends Serializable>> rootTasks, Task<? extends Serializable> fetchTask, String astStringTree, BaseSemanticAnalyzer analyzer, boolean extended, boolean formatted, boolean dependency, boolean logical, boolean authorize, boolean userLevelExplain, String cboInfo)

Uses of Task in org.apache.hadoop.hive.ql.stats

Methods in org.apache.hadoop.hive.ql.stats with parameters of type Task

Modifier and Type	Method and Description
boolean	StatsAggregator.connect(org.apache.hadoop.conf.Configuration hconf, Task sourceTask) This method connects to the temporary storage.
boolean	CounterStatsAggregatorTez.connect(org.apache.hadoop.conf.Configuration hconf, Task sourceTask)
boolean	CounterStatsAggregatorSpark.connect(org.apache.hadoop.conf.Configuration hconf, Task sourceTask)
boolean	CounterStatsAggregator.connect(org.apache.hadoop.conf.Configuration hconf, Task sourceTask)

Uses of Task in org.apache.hadoop.hive.ql.stats.fs

Methods in org.apache.hadoop.hive.ql.stats.fs with parameters of type Task

Modifier and Type	Method and Description
boolean	FSStatsAggregator.connect(org.apache.hadoop.conf.Configuration hconf, Task sourceTask)

Uses of Task in org.apache.hadoop.hive.ql.stats.jdbc

Methods in org.apache.hadoop.hive.ql.stats.jdbc with parameters of type Task

Modifier and Type	Method and Description
boolean	JDBCStatsAggregator.connect(org.apache.hadoop.conf.Configuration hiveconf, Task sourceTask)

Uses of Task in org.apache.hive.hcatalog.cli.SemanticAnalysis

Method parameters in org.apache.hive.hcatalog.cli.SemanticAnalysis with type arguments of type Task

Modifier and Type	Method and Description
protected void	HCatSemanticAnalyzerBase.authorizeDDL(HiveSemanticAnalyzerHookContext context, List<Task<? extends Serializable>> rootTasks) Checks for the given rootTasks, and calls authorizeDDLWork() for each DDLWork to be authorized.
void	HCatSemanticAnalyzerBase.postAnalyze(HiveSemanticAnalyzerHookContext context, List<Task<? extends Serializable>> rootTasks)
void	HCatSemanticAnalyzer.postAnalyze(HiveSemanticAnalyzerHookContext context, List<Task<? extends Serializable>> rootTasks)