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.hooks | |
org.apache.hadoop.hive.ql.io.merge | |
org.apache.hadoop.hive.ql.io.rcfile.truncate | |
org.apache.hadoop.hive.ql.parse | |
org.apache.hadoop.hive.ql.reexec | |
org.apache.hive.service.cli.operation |
Modifier and Type | Method and Description |
---|---|
QueryState |
QueryState.Builder.build()
Creates the QueryState object.
|
QueryState |
Driver.getQueryState() |
Modifier and Type | Method and Description |
---|---|
static IDriver |
DriverFactory.newDriver(QueryState queryState,
String userName,
QueryInfo queryInfo) |
Constructor and Description |
---|
Driver(QueryState queryState,
String userName) |
Driver(QueryState queryState,
String userName,
QueryInfo queryInfo) |
Driver(QueryState queryState,
String userName,
QueryInfo queryInfo,
HiveTxnManager txnMgr) |
Modifier and Type | Field and Description |
---|---|
protected QueryState |
Task.queryState |
Modifier and Type | Method and Description |
---|---|
QueryState |
Task.getQueryState() |
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) |
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 |
---|---|
QueryState |
HookContext.getQueryState() |
Modifier and Type | Method and Description |
---|---|
void |
PostExecutePrinter.run(QueryState queryState,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
LineageInfo linfo,
org.apache.hadoop.security.UserGroupInformation ugi) |
void |
PreExecutePrinter.run(QueryState queryState,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
org.apache.hadoop.security.UserGroupInformation ugi) |
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 | Field and Description |
---|---|
protected QueryState |
TaskCompiler.queryState |
protected QueryState |
BaseSemanticAnalyzer.queryState |
Modifier and Type | Method and Description |
---|---|
QueryState |
ParseContext.getQueryState() |
QueryState |
BaseSemanticAnalyzer.getQueryState() |
Modifier and Type | Method and Description |
---|---|
static BaseSemanticAnalyzer |
SemanticAnalyzerFactory.get(QueryState queryState,
ASTNode tree) |
void |
TaskCompiler.init(QueryState queryState,
SessionState.LogHelper console,
Hive db) |
void |
TezCompiler.init(QueryState queryState,
SessionState.LogHelper console,
Hive db) |
Constructor and Description |
---|
ReExecDriver(QueryState queryState,
String userName,
QueryInfo queryInfo,
ArrayList<IReExecutionPlugin> plugins) |
Modifier and Type | Field and Description |
---|---|
protected QueryState |
Operation.queryState |
Modifier and Type | Method and Description |
---|---|
void |
SQLOperation.prepare(QueryState queryState)
Compile the query and extract metadata
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.