Modifier and Type | Method and Description |
---|---|
HashSet<ReadEntity> |
QueryPlan.getInputs() |
Modifier and Type | Method and Description |
---|---|
void |
QueryPlan.setInputs(HashSet<ReadEntity> inputs) |
Modifier and Type | Method and Description |
---|---|
Set<ReadEntity> |
HookContext.getInputs() |
Set<ReadEntity> |
ReadEntity.getParents() |
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) |
void |
PostExecute.run(SessionState sess,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
LineageInfo lInfo,
org.apache.hadoop.security.UserGroupInformation ugi)
Deprecated.
|
void |
UpdateInputAccessTimeHook.PreExec.run(SessionState sess,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
org.apache.hadoop.security.UserGroupInformation ugi) |
void |
PreExecute.run(SessionState sess,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
org.apache.hadoop.security.UserGroupInformation ugi)
Deprecated.
|
void |
EnforceReadOnlyTables.run(SessionState sess,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
org.apache.hadoop.security.UserGroupInformation ugi) |
void |
HookContext.setInputs(Set<ReadEntity> inputs) |
Constructor and Description |
---|
ReadEntity(Partition p,
ReadEntity parent) |
ReadEntity(Partition p,
ReadEntity parent,
boolean isDirect) |
ReadEntity(Table t,
ReadEntity parent) |
ReadEntity(Table t,
ReadEntity parent,
boolean isDirect) |
Modifier and Type | Method and Description |
---|---|
Set<ReadEntity> |
HiveIndexQueryContext.getAdditionalSemanticInputs() |
Modifier and Type | Method and Description |
---|---|
void |
HiveIndexQueryContext.addAdditionalSemanticInputs(Set<ReadEntity> additionalParseInputs) |
List<Task<?>> |
TableBasedIndexHandler.generateIndexBuildTaskList(Table baseTbl,
Index index,
List<Partition> indexTblPartitions,
List<Partition> baseTblPartitions,
Table indexTbl,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
List<Task<?>> |
HiveIndexHandler.generateIndexBuildTaskList(Table baseTbl,
Index index,
List<Partition> indexTblPartitions,
List<Partition> baseTblPartitions,
Table indexTbl,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs)
Requests that the handler generate a plan for building the index; the plan
should read the base table and write out the index representation.
|
protected Task<?> |
TableBasedIndexHandler.getIndexBuilderMapRedTask(Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
Index index,
boolean partitioned,
PartitionDesc indexTblPartDesc,
String indexTableName,
PartitionDesc baseTablePartDesc,
String baseTableName,
String dbName) |
protected Task<?> |
AggregateIndexHandler.getIndexBuilderMapRedTask(Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
Index index,
boolean partitioned,
PartitionDesc indexTblPartDesc,
String indexTableName,
PartitionDesc baseTablePartDesc,
String baseTableName,
String dbName) |
protected Task<?> |
TableBasedIndexHandler.getIndexBuilderMapRedTask(Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
List<FieldSchema> indexField,
boolean partitioned,
PartitionDesc indexTblPartDesc,
String indexTableName,
PartitionDesc baseTablePartDesc,
String baseTableName,
String dbName) |
Modifier and Type | Method and Description |
---|---|
protected Task<?> |
BitmapIndexHandler.getIndexBuilderMapRedTask(Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
List<FieldSchema> indexField,
boolean partitioned,
PartitionDesc indexTblPartDesc,
String indexTableName,
PartitionDesc baseTablePartDesc,
String baseTableName,
String dbName) |
Modifier and Type | Method and Description |
---|---|
protected Task<?> |
CompactIndexHandler.getIndexBuilderMapRedTask(Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
List<FieldSchema> indexField,
boolean partitioned,
PartitionDesc indexTblPartDesc,
String indexTableName,
PartitionDesc baseTablePartDesc,
String baseTableName,
String dbName) |
Modifier and Type | Method and Description |
---|---|
Set<ReadEntity> |
GenMRProcContext.getInputs()
Get the input set.
|
Modifier and Type | Method and Description |
---|---|
static Task<?> |
IndexUtils.createRootTask(HiveConf builderConf,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
StringBuilder command,
LinkedHashMap<String,String> partSpec,
String indexTableName,
String dbName) |
static void |
GenMapRedUtils.setMapWork(MapWork plan,
ParseContext parseCtx,
Set<ReadEntity> inputs,
PrunedPartitionList partsList,
TableScanOperator tsOp,
String alias_id,
HiveConf conf,
boolean local)
initialize MapWork
|
Constructor and Description |
---|
GenMRProcContext(HiveConf conf,
HashMap<Operator<? extends OperatorDesc>,Task<? extends Serializable>> opTaskMap,
ParseContext parseCtx,
List<Task<MoveWork>> mvTask,
List<Task<? extends Serializable>> rootTasks,
LinkedHashMap<Operator<? extends OperatorDesc>,GenMRProcContext.GenMapRedCtx> mapCurrCtx,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
Modifier and Type | Field and Description |
---|---|
Set<ReadEntity> |
OptimizeTezProcContext.inputs |
Set<ReadEntity> |
GenTezProcContext.inputs |
protected HashSet<ReadEntity> |
BaseSemanticAnalyzer.inputs
ReadEntities that are passed to the hooks.
|
Modifier and Type | Method and Description |
---|---|
protected ReadEntity |
BaseSemanticAnalyzer.toReadEntity(org.apache.hadoop.fs.Path location) |
protected ReadEntity |
BaseSemanticAnalyzer.toReadEntity(String location) |
Modifier and Type | Method and Description |
---|---|
HashSet<ReadEntity> |
SemanticAnalyzer.getAllInputs() |
HashSet<ReadEntity> |
BaseSemanticAnalyzer.getAllInputs() |
Set<ReadEntity> |
HiveSemanticAnalyzerHookContextImpl.getInputs() |
Set<ReadEntity> |
HiveSemanticAnalyzerHookContext.getInputs()
The following methods will only be available to hooks executing postAnalyze.
|
HashSet<ReadEntity> |
BaseSemanticAnalyzer.getInputs() |
HashSet<ReadEntity> |
ParseContext.getSemanticInputs() |
Map<String,ReadEntity> |
ParseContext.getViewAliasToInput() |
Modifier and Type | Method and Description |
---|---|
void |
TaskCompiler.compile(ParseContext pCtx,
List<Task<? extends Serializable>> rootTasks,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
protected void |
TezCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks,
ParseContext pCtx,
List<Task<MoveWork>> mvTask,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
protected abstract void |
TaskCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks,
ParseContext pCtx,
List<Task<MoveWork>> mvTask,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
protected void |
MapReduceCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks,
ParseContext pCtx,
List<Task<MoveWork>> mvTask,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
protected void |
TezCompiler.optimizeOperatorPlan(ParseContext pCtx,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
protected void |
TaskCompiler.optimizeOperatorPlan(ParseContext pCtxSet,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
Modifier and Type | Method and Description |
---|---|
Task<? extends Serializable> |
HiveAuthorizationTaskFactoryImpl.createCreateRoleTask(ASTNode ast,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactory.createCreateRoleTask(ASTNode node,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactoryImpl.createDropRoleTask(ASTNode ast,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactory.createDropRoleTask(ASTNode node,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactoryImpl.createGrantRoleTask(ASTNode ast,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactory.createGrantRoleTask(ASTNode node,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactoryImpl.createGrantTask(ASTNode ast,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactory.createGrantTask(ASTNode node,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactoryImpl.createRevokeRoleTask(ASTNode ast,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactory.createRevokeRoleTask(ASTNode node,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactoryImpl.createRevokeTask(ASTNode ast,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactory.createRevokeTask(ASTNode node,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactoryImpl.createSetRoleTask(String roleName,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactory.createSetRoleTask(String roleName,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactoryImpl.createShowCurrentRoleTask(HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs,
org.apache.hadoop.fs.Path resFile) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactory.createShowCurrentRoleTask(HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs,
org.apache.hadoop.fs.Path resFile) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactoryImpl.createShowGrantTask(ASTNode ast,
org.apache.hadoop.fs.Path resultFile,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactory.createShowGrantTask(ASTNode node,
org.apache.hadoop.fs.Path resultFile,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactoryImpl.createShowRoleGrantTask(ASTNode ast,
org.apache.hadoop.fs.Path resultFile,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactory.createShowRoleGrantTask(ASTNode node,
org.apache.hadoop.fs.Path resultFile,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactoryImpl.createShowRolePrincipalsTask(ASTNode ast,
org.apache.hadoop.fs.Path resFile,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactory.createShowRolePrincipalsTask(ASTNode ast,
org.apache.hadoop.fs.Path resFile,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactoryImpl.createShowRolesTask(ASTNode ast,
org.apache.hadoop.fs.Path resFile,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Task<? extends Serializable> |
HiveAuthorizationTaskFactory.createShowRolesTask(ASTNode ast,
org.apache.hadoop.fs.Path resFile,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
Modifier and Type | Field and Description |
---|---|
Set<ReadEntity> |
GenSparkProcContext.inputs |
Modifier and Type | Method and Description |
---|---|
Set<ReadEntity> |
OptimizeSparkProcContext.getInputs() |
Modifier and Type | Method and Description |
---|---|
protected void |
SparkCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks,
ParseContext pCtx,
List<Task<MoveWork>> mvTask,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs)
TODO: need to turn on rules that's commented out and add more if necessary.
|
protected void |
SparkCompiler.optimizeOperatorPlan(ParseContext pCtx,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
Constructor and Description |
---|
GenSparkProcContext(HiveConf conf,
ParseContext parseContext,
List<Task<MoveWork>> moveTask,
List<Task<? extends Serializable>> rootTasks,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
Map<String,TableScanOperator> topOps) |
OptimizeSparkProcContext(HiveConf conf,
ParseContext parseContext,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
Modifier and Type | Field and Description |
---|---|
protected HashSet<ReadEntity> |
MoveWork.inputs
ReadEntitites that are passed to the hooks.
|
protected HashSet<ReadEntity> |
DDLWork.inputs
ReadEntitites that are passed to the hooks.
|
Modifier and Type | Method and Description |
---|---|
static ReadEntity |
PlanUtils.addInput(Set<ReadEntity> inputs,
ReadEntity newInput) |
static ReadEntity |
PlanUtils.addInput(Set<ReadEntity> inputs,
ReadEntity newInput,
boolean mergeIsDirectFlag) |
static ReadEntity |
PlanUtils.getParentViewInfo(String alias_id,
Map<String,ReadEntity> viewAliasToInput) |
Modifier and Type | Method and Description |
---|---|
HashSet<ReadEntity> |
MoveWork.getInputs() |
HashSet<ReadEntity> |
ExplainWork.getInputs() |
HashSet<ReadEntity> |
DDLWork.getInputs() |
Modifier and Type | Method and Description |
---|---|
static ReadEntity |
PlanUtils.addInput(Set<ReadEntity> inputs,
ReadEntity newInput) |
static ReadEntity |
PlanUtils.addInput(Set<ReadEntity> inputs,
ReadEntity newInput,
boolean mergeIsDirectFlag) |
static void |
PlanUtils.addPartitionInputs(Collection<Partition> parts,
Collection<ReadEntity> inputs,
ReadEntity parentViewInfo,
boolean isDirectRead) |
Modifier and Type | Method and Description |
---|---|
static ReadEntity |
PlanUtils.addInput(Set<ReadEntity> inputs,
ReadEntity newInput) |
static ReadEntity |
PlanUtils.addInput(Set<ReadEntity> inputs,
ReadEntity newInput,
boolean mergeIsDirectFlag) |
static void |
PlanUtils.addPartitionInputs(Collection<Partition> parts,
Collection<ReadEntity> inputs,
ReadEntity parentViewInfo,
boolean isDirectRead) |
static ReadEntity |
PlanUtils.getParentViewInfo(String alias_id,
Map<String,ReadEntity> viewAliasToInput) |
void |
MoveWork.setInputs(HashSet<ReadEntity> inputs) |
void |
ExplainWork.setInputs(HashSet<ReadEntity> inputs) |
void |
DDLWork.setInputs(HashSet<ReadEntity> inputs) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.