Package | Description |
---|---|
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.spark.session | |
org.apache.hadoop.hive.ql.exec.tez | |
org.apache.hadoop.hive.ql.index | |
org.apache.hadoop.hive.ql.io.merge | |
org.apache.hadoop.hive.ql.io.rcfile.stats | |
org.apache.hadoop.hive.ql.io.rcfile.truncate |
Modifier and Type | Field and Description |
---|---|
protected DriverContext |
Task.driverContext |
Modifier and Type | Method and Description |
---|---|
protected abstract int |
Task.execute(DriverContext driverContext)
This method is overridden in each Task.
|
int |
StatsTask.execute(DriverContext driverContext) |
int |
StatsNoJobTask.execute(DriverContext driverContext) |
int |
MoveTask.execute(DriverContext driverContext) |
int |
FunctionTask.execute(DriverContext driverContext) |
int |
FetchTask.execute(DriverContext driverContext) |
int |
ExplainTask.execute(DriverContext driverContext) |
int |
ExplainSQRewriteTask.execute(DriverContext driverContext) |
int |
DependencyCollectionTask.execute(DriverContext driverContext) |
int |
DDLTask.execute(DriverContext driverContext) |
int |
CopyTask.execute(DriverContext driverContext) |
int |
ConditionalTask.execute(DriverContext driverContext) |
int |
ColumnStatsUpdateTask.execute(DriverContext driverContext) |
int |
ColumnStatsTask.execute(DriverContext driverContext) |
void |
Task.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext) |
void |
StatsNoJobTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext) |
void |
FunctionTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext ctx) |
void |
FetchTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext ctx) |
void |
DDLTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext ctx) |
void |
ConditionalTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext) |
void |
ColumnStatsUpdateTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext ctx) |
void |
ColumnStatsTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext ctx) |
Modifier and Type | Method and Description |
---|---|
int |
MapRedTask.execute(DriverContext driverContext) |
int |
MapredLocalTask.execute(DriverContext driverContext) |
int |
ExecDriver.execute(DriverContext driverContext)
Execute a query plan using Hadoop.
|
int |
MapredLocalTask.executeInChildVM(DriverContext driverContext) |
int |
MapredLocalTask.executeInProcess(DriverContext driverContext) |
void |
MapredLocalTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext) |
void |
ExecDriver.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext)
Initialization when invoked from QL.
|
Modifier and Type | Method and Description |
---|---|
int |
SparkTask.execute(DriverContext driverContext) |
SparkJobRef |
RemoteHiveSparkClient.execute(DriverContext driverContext,
SparkWork sparkWork) |
SparkJobRef |
LocalHiveSparkClient.execute(DriverContext driverContext,
SparkWork sparkWork) |
SparkJobRef |
HiveSparkClient.execute(DriverContext driverContext,
SparkWork sparkWork)
HiveSparkClient should generate Spark RDD graph by given sparkWork and driverContext,
and submit RDD graph to Spark cluster.
|
void |
SparkTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext) |
Modifier and Type | Method and Description |
---|---|
SparkJobRef |
SparkSessionImpl.submit(DriverContext driverContext,
SparkWork sparkWork) |
SparkJobRef |
SparkSession.submit(DriverContext driverContext,
SparkWork sparkWork)
Submit given sparkWork to SparkClient.
|
Modifier and Type | Method and Description |
---|---|
int |
TezTask.execute(DriverContext driverContext) |
Modifier and Type | Method and Description |
---|---|
protected int |
IndexMetadataChangeTask.execute(DriverContext driverContext) |
Modifier and Type | Method and Description |
---|---|
int |
MergeFileTask.execute(DriverContext driverContext)
start a new map-reduce job to do the merge, almost the same as ExecDriver.
|
void |
MergeFileTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext) |
Modifier and Type | Method and Description |
---|---|
int |
PartialScanTask.execute(DriverContext driverContext) |
void |
PartialScanTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext) |
Modifier and Type | Method and Description |
---|---|
int |
ColumnTruncateTask.execute(DriverContext driverContext) |
void |
ColumnTruncateTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.