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.truncate | |
org.apache.hadoop.hive.ql.lockmgr |
Hive Lock Manager interfaces and some custom implmentations
|
org.apache.hadoop.hive.ql.reexec |
Modifier and Type | Method and Description |
---|---|
QueryPlan |
Driver.getPlan() |
QueryPlan |
IDriver.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 |
FetchTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
void |
Task.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
void |
FunctionTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
void |
ColumnStatsUpdateTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
void |
StatsTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
void |
DDLTask.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 |
---|---|
static List<LineageLogger.Edge> |
LineageLogger.getEdges(QueryPlan plan,
LineageCtx.Index index)
Based on the final select operator, find out all the target columns.
|
protected org.apache.hadoop.hive.ql.hooks.ATSHook.ExecutionMode |
ATSHook.getExecutionMode(QueryPlan plan) |
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 hiveInstanceAddress,
String operationId,
String sessionId,
String threadId,
boolean isHiveServerQuery,
PerfLogger perfLogger,
QueryInfo queryInfo) |
PrivateHookContext(QueryPlan queryPlan,
QueryState queryState,
Map<String,org.apache.hadoop.fs.ContentSummary> inputPathToContentSummary,
String userName,
String ipAddress,
String hiveInstanceAddress,
String operationId,
String sessionId,
String threadId,
boolean isHiveServerQuery,
PerfLogger perfLogger,
QueryInfo queryInfo,
Context ctx) |
Modifier and Type | Method and Description |
---|---|
void |
MergeFileTask.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 |
DbTxnManager.acquireLocks(QueryPlan plan,
Context ctx,
String username) |
void |
HiveTxnManager.acquireLocks(QueryPlan plan,
Context ctx,
String username)
Acquire all of the locks needed by a query.
|
void |
HiveTxnManager.acquireLocks(QueryPlan plan,
Context ctx,
String username,
Driver.LockedDriverState lDrvState)
Acquire all of the locks needed by a query.
|
boolean |
DbTxnManager.recordSnapshot(QueryPlan queryPlan)
In an explicit txn start_transaction is the 1st statement and we record the snapshot at the
start of the txn for Snapshot Isolation.
|
boolean |
HiveTxnManager.recordSnapshot(QueryPlan queryPlan)
For resources that support MVCC, the state of the DB must be recorded for the duration of the
operation/transaction.
|
Modifier and Type | Method and Description |
---|---|
QueryPlan |
ReExecDriver.getPlan() |
Copyright © 2022 The Apache Software Foundation. All rights reserved.