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.exec.tez | |
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
|
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(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
void |
StatsNoJobTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
void |
FunctionTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
void |
FetchTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
void |
DDLTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
void |
ColumnStatsUpdateTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
void |
ColumnStatsTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
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(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
void |
ExecDriver.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext)
Initialization when invoked from QL.
|
Modifier and Type | Method and Description |
---|---|
void |
SparkTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
Modifier and Type | Method and Description |
---|---|
String |
DagUtils.createDagName(org.apache.hadoop.conf.Configuration conf,
QueryPlan plan) |
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,
QueryState queryState,
Map<String,org.apache.hadoop.fs.ContentSummary> inputPathToContentSummary,
String userName,
String ipAddress,
String operationId) |
Modifier and Type | Method and Description |
---|---|
void |
MergeFileTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
Modifier and Type | Method and Description |
---|---|
void |
PartialScanTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnTruncateTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
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) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.