Package | Description |
---|---|
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.history | |
org.apache.hadoop.hive.ql.hooks | |
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.lockmgr |
Hive Lock Manager interfaces and some custom implmentations
|
org.apache.hadoop.hive.ql.log |
Modifier and Type | Method and Description |
---|---|
QueryPlan |
Driver.getPlan() |
Modifier and Type | Method and Description |
---|---|
void |
DriverContext.prepare(QueryPlan plan) |
Modifier and Type | Field and Description |
---|---|
protected QueryPlan |
Task.queryPlan |
Modifier and Type | Method and Description |
---|---|
QueryPlan |
Task.getQueryPlan() |
Modifier and Type | Method and Description |
---|---|
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) |
void |
Task.setQueryPlan(QueryPlan queryPlan) |
static void |
Utilities.setWorkflowAdjacencies(org.apache.hadoop.conf.Configuration conf,
QueryPlan plan) |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
void |
SparkTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext) |
Modifier and Type | Method and Description |
---|---|
void |
HiveHistoryImpl.logPlanProgress(QueryPlan plan) |
void |
HiveHistory.logPlanProgress(QueryPlan plan)
Logs the current plan state
|
Modifier and Type | Method and Description |
---|---|
QueryPlan |
HookContext.getQueryPlan() |
Modifier and Type | Method and Description |
---|---|
void |
HookContext.setQueryPlan(QueryPlan queryPlan) |
Constructor and Description |
---|
HookContext(QueryPlan queryPlan,
HiveConf conf,
Map<String,org.apache.hadoop.fs.ContentSummary> inputPathToContentSummary,
String userName,
String ipAddress,
String operationId) |
Modifier and Type | Method and Description |
---|---|
void |
MergeFileTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext) |
Modifier and Type | Method and Description |
---|---|
void |
PartialScanTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnTruncateTask.initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext driverContext) |
Modifier and Type | Method and Description |
---|---|
void |
HiveTxnManager.acquireLocks(QueryPlan plan,
Context ctx,
String username)
Acquire all of the locks needed by a query.
|
void |
DbTxnManager.acquireLocks(QueryPlan plan,
Context ctx,
String username) |
Modifier and Type | Method and Description |
---|---|
void |
PerfLogger.close(org.apache.commons.logging.Log _log,
QueryPlan queryPlan)
Call this function at the end of processing a query (any time after the last call to PerfLogEnd
for a given query) to run any cleanup/final steps that need to be run
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.