Package | Description |
---|---|
org.apache.hadoop.hive.ql.optimizer | |
org.apache.hadoop.hive.ql.optimizer.correlation | |
org.apache.hadoop.hive.ql.optimizer.lineage | |
org.apache.hadoop.hive.ql.optimizer.metainfo.annotation | |
org.apache.hadoop.hive.ql.parse | |
org.apache.hadoop.hive.ql.udf.generic |
Standard toolkit and framework for generic User-defined functions.
|
Modifier and Type | Method and Description |
---|---|
List<FieldNode> |
ColumnPrunerProcCtx.getColsFromSelectExpr(SelectOperator op)
Creates the list of internal column names (represented by field nodes)
from select expressions in a select operator.
|
List<FieldNode> |
ColumnPrunerProcCtx.getSelectColsFromChildren(SelectOperator op,
List<FieldNode> colList)
Creates the list of internal column names for select * expressions.
|
Modifier and Type | Method and Description |
---|---|
protected static SelectOperator |
CorrelationUtilities.replaceReduceSinkWithSelectOperator(ReduceSinkOperator childRS,
ParseContext context,
org.apache.hadoop.hive.ql.optimizer.correlation.AbstractCorrelationProcCtx procCtx) |
Modifier and Type | Method and Description |
---|---|
Map<String,org.apache.commons.lang3.tuple.Pair<SelectOperator,Table>> |
LineageCtx.Index.getFinalSelectOps() |
Modifier and Type | Method and Description |
---|---|
void |
LineageCtx.Index.addFinalSelectOp(SelectOperator sop,
Operator<? extends OperatorDesc> sinkOp) |
Modifier and Type | Method and Description |
---|---|
List<List<String>> |
OpTraitsRulesProcFactory.SelectRule.getConvertedColNames(List<List<String>> parentColNames,
SelectOperator selOp,
boolean processSortCols) |
Modifier and Type | Method and Description |
---|---|
Map<SelectOperator,Table> |
ParseContext.getViewProjectToTableSchema() |
Constructor and Description |
---|
ParseContext(QueryState queryState,
Map<TableScanOperator,ExprNodeDesc> opToPartPruner,
Map<TableScanOperator,PrunedPartitionList> opToPartList,
Map<String,TableScanOperator> topOps,
Set<JoinOperator> joinOps,
Set<SMBMapJoinOperator> smbMapJoinOps,
List<LoadTableDesc> loadTableWork,
List<LoadFileDesc> loadFileWork,
List<ColumnStatsAutoGatherContext> columnStatsAutoGatherContexts,
Context ctx,
Map<String,String> idToTableNameMap,
int destTableId,
UnionProcContext uCtx,
List<AbstractMapJoinOperator<? extends MapJoinDesc>> listMapJoinOpsNoReducer,
Map<String,PrunedPartitionList> prunedPartitions,
QueryTables tabNameToTabObject,
Map<TableScanOperator,FilterDesc.SampleDesc> opToSamplePruner,
GlobalLimitCtx globalLimitCtx,
Map<String,SplitSample> nameToSplitSample,
Set<ReadEntity> semanticInputs,
List<Task<?>> rootTasks,
Map<TableScanOperator,Map<String,ExprNodeDesc>> opToPartToSkewedPruner,
Map<String,ReadEntity> viewAliasToInput,
List<ReduceSinkOperator> reduceSinkOperatorsAddedByEnforceBucketingSorting,
BaseSemanticAnalyzer.AnalyzeRewriteContext analyzeRewrite,
CreateTableDesc createTableDesc,
CreateMaterializedViewDesc createViewDesc,
MaterializedViewUpdateDesc materializedViewUpdateDesc,
QueryProperties queryProperties,
Map<SelectOperator,Table> viewProjectToTableSchema) |
Modifier and Type | Method and Description |
---|---|
void |
GenericUDAFBloomFilter.GenericUDAFBloomFilterEvaluator.setSourceOperator(SelectOperator sourceOperator) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.