public class ParseContext extends Object
Constructor and Description |
---|
ParseContext() |
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) |
public ParseContext()
public 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)
opToPartPruner
- map from table scan operator to partition pruneropToPartList
- topOps
- list of operators for the top queryjoinOps
- context needed join processing (map join specifically)smbMapJoinOps
- loadTableWork
- list of destination tables being loadedloadFileWork
- list of destination files being loadedctx
- parse contextidToTableNameMap
- uCtx
- destTableId
- listMapJoinOpsNoReducer
- list of map join operators with no reducerprunedPartitions
- opToSamplePruner
- operator to sample pruner mapglobalLimitCtx
- nameToSplitSample
- rootTasks
- opToPartToSkewedPruner
- viewAliasToInput
- reduceSinkOperatorsAddedByEnforceBucketingSorting
- analyzeRewrite
- createTableDesc
- createViewDesc
- queryProperties
- public Context getContext()
public void setContext(Context ctx)
ctx
- the context to setpublic HiveConf getConf()
public void setConf(HiveConf conf)
conf
- the conf to setpublic QueryState getQueryState()
public Map<TableScanOperator,ExprNodeDesc> getOpToPartPruner()
public void setOpToPartPruner(Map<TableScanOperator,ExprNodeDesc> opToPartPruner)
opToPartPruner
- the opToPartPruner to setpublic Map<TableScanOperator,PrunedPartitionList> getOpToPartList()
public List<ReduceSinkOperator> getReduceSinkOperatorsAddedByEnforceBucketingSorting()
public void setReduceSinkOperatorsAddedByEnforceBucketingSorting(List<ReduceSinkOperator> reduceSinkOperatorsAddedByEnforceBucketingSorting)
public Map<String,TableScanOperator> getTopOps()
public void setTopOps(Map<String,TableScanOperator> topOps)
topOps
- the topOps to setpublic Map<String,SplitSample> getNameToSplitSample()
public void setNameToSplitSample(Map<String,SplitSample> nameToSplitSample)
public List<LoadTableDesc> getLoadTableWork()
public List<LoadFileDesc> getLoadFileWork()
public void setLoadFileWork(List<LoadFileDesc> loadFileWork)
loadFileWork
- the loadFileWork to setpublic int getDestTableId()
public void setDestTableId(int destTableId)
public UnionProcContext getUCtx()
public void setUCtx(UnionProcContext uCtx)
public Set<JoinOperator> getJoinOps()
public void setJoinOps(Set<JoinOperator> joinOps)
joinOps
- the joinOps to setpublic List<AbstractMapJoinOperator<? extends MapJoinDesc>> getListMapJoinOpsNoReducer()
public void setListMapJoinOpsNoReducer(List<AbstractMapJoinOperator<? extends MapJoinDesc>> listMapJoinOpsNoReducer)
listMapJoinOpsNoReducer
- the listMapJoinOpsNoReducer to setpublic Map<TableScanOperator,FilterDesc.SampleDesc> getOpToSamplePruner()
public void setOpToSamplePruner(Map<TableScanOperator,FilterDesc.SampleDesc> opToSamplePruner)
opToSamplePruner
- the opToSamplePruner to setpublic Map<String,ColumnStatsList> getColStatsCache()
public ColumnStatsList getColStatsCached(PrunedPartitionList partList)
partList
- public Map<String,PrunedPartitionList> getPrunedPartitions()
public void setPrunedPartitions(Map<String,PrunedPartitionList> prunedPartitions)
prunedPartitions
- public void setLineageInfo(LineageInfo lInfo)
lInfo
- The lineage information.public LineageInfo getLineageInfo()
public Set<MapJoinOperator> getMapJoinOps()
public void setMapJoinOps(Set<MapJoinOperator> mapJoinOps)
public Set<SMBMapJoinOperator> getSmbMapJoinOps()
public void setSmbMapJoinOps(Set<SMBMapJoinOperator> smbMapJoinOps)
public GlobalLimitCtx getGlobalLimitCtx()
public void setGlobalLimitCtx(GlobalLimitCtx globalLimitCtx)
public Set<ReadEntity> getSemanticInputs()
public FetchTask getFetchTask()
public void setFetchTask(FetchTask fetchTask)
public PrunedPartitionList getPrunedPartitions(TableScanOperator ts) throws SemanticException
SemanticException
public PrunedPartitionList getPrunedPartitions(String alias, TableScanOperator ts) throws SemanticException
SemanticException
public Map<TableScanOperator,Map<String,ExprNodeDesc>> getOpToPartToSkewedPruner()
public void setOpPartToSkewedPruner(Map<TableScanOperator,Map<String,ExprNodeDesc>> opToPartToSkewedPruner)
opToPartToSkewedPruner
- the opToSkewedPruner to setpublic Map<String,ReadEntity> getViewAliasToInput()
public QueryProperties getQueryProperties()
public void setQueryProperties(QueryProperties queryProperties)
public TableDesc getFetchTableDesc()
public void setFetchTabledesc(TableDesc fetchTableDesc)
public Operator<?> getFetchSource()
public void setFetchSource(Operator<?> fetchSource)
public ListSinkOperator getFetchSink()
public void setFetchSink(ListSinkOperator fetchSink)
public BaseSemanticAnalyzer.AnalyzeRewriteContext getAnalyzeRewrite()
public void setAnalyzeRewrite(BaseSemanticAnalyzer.AnalyzeRewriteContext analyzeRewrite)
public CreateTableDesc getCreateTable()
public void setCreateTable(CreateTableDesc createTableDesc)
public CreateMaterializedViewDesc getCreateViewDesc()
public MaterializedViewUpdateDesc getMaterializedViewUpdateDesc()
public void setReduceSinkAddedBySortedDynPartition(boolean reduceSinkAddedBySortedDynPartition)
public boolean isReduceSinkAddedBySortedDynPartition()
public Map<SelectOperator,Table> getViewProjectToTableSchema()
public ColumnAccessInfo getColumnAccessInfo()
public void setColumnAccessInfo(ColumnAccessInfo columnAccessInfo)
public boolean isNeedViewColumnAuthorization()
public void setNeedViewColumnAuthorization(boolean needViewColumnAuthorization)
public QueryTables getTabNameToTabObject()
public List<ColumnStatsAutoGatherContext> getColumnStatsAutoGatherContexts()
public void setColumnStatsAutoGatherContexts(List<ColumnStatsAutoGatherContext> columnStatsAutoGatherContexts)
public Collection<Operator> getAllOps()
public void setRsToRuntimeValuesInfoMap(Map<ReduceSinkOperator,RuntimeValuesInfo> rsToRuntimeValuesInfo)
public Map<ReduceSinkOperator,RuntimeValuesInfo> getRsToRuntimeValuesInfoMap()
public void setRsToSemiJoinBranchInfo(LinkedHashMap<ReduceSinkOperator,SemiJoinBranchInfo> rsToSemiJoinBranchInfo)
public LinkedHashMap<ReduceSinkOperator,SemiJoinBranchInfo> getRsToSemiJoinBranchInfo()
public void setColExprToGBMap(Map<ExprNodeDesc,GroupByOperator> colExprToGBMap)
public Map<ExprNodeDesc,GroupByOperator> getColExprToGBMap()
public void setSemiJoinHints(Map<String,List<SemiJoinHint>> hints)
public Map<String,List<SemiJoinHint>> getSemiJoinHints()
public void setDisableMapJoin(boolean disableMapJoin)
public boolean getDisableMapJoin()
public void setTerminalOpToRSMap(com.google.common.collect.Multimap<TerminalOperator<?>,ReduceSinkOperator> terminalOpToRSMap)
public com.google.common.collect.Multimap<TerminalOperator<?>,ReduceSinkOperator> getTerminalOpToRSMap()
Copyright © 2023 The Apache Software Foundation. All rights reserved.