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.stats | |
org.apache.hadoop.hive.ql.io.rcfile.truncate | |
org.apache.hadoop.hive.ql.optimizer.index | |
org.apache.hadoop.hive.ql.parse | |
org.apache.hive.service.cli.operation |
Constructor and Description |
---|
Driver(QueryState queryState,
String userName) |
Modifier and Type | Field and Description |
---|---|
protected QueryState |
Task.queryState |
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) |
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.
|
Constructor and Description |
---|
HadoopJobExecHelper(QueryState queryState,
org.apache.hadoop.mapred.JobConf job,
SessionState.LogHelper console,
Task<? extends Serializable> task,
HadoopJobExecHook hookCallBack) |
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 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 |
---|---|
static Operator<? extends OperatorDesc> |
RewriteParseContextGenerator.generateOperatorTree(QueryState queryState,
String command)
Parse the input
String command and generate an operator tree. |
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 |
TezCompiler.init(QueryState queryState,
SessionState.LogHelper console,
Hive db) |
void |
TaskCompiler.init(QueryState queryState,
SessionState.LogHelper console,
Hive db) |
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 © 2016 The Apache Software Foundation. All rights reserved.