public class ParseContext
extends java.lang.Object
Constructor and Description |
---|
ParseContext() |
ParseContext(HiveConf conf,
QB qb,
ASTNode ast,
java.util.HashMap<TableScanOperator,ExprNodeDesc> opToPartPruner,
java.util.HashMap<TableScanOperator,PrunedPartitionList> opToPartList,
java.util.HashMap<java.lang.String,Operator<? extends OperatorDesc>> topOps,
java.util.HashMap<java.lang.String,Operator<? extends OperatorDesc>> topSelOps,
java.util.LinkedHashMap<Operator<? extends OperatorDesc>,OpParseContext> opParseCtx,
java.util.Map<JoinOperator,QBJoinTree> joinContext,
java.util.Map<SMBMapJoinOperator,QBJoinTree> smbMapJoinContext,
java.util.HashMap<TableScanOperator,Table> topToTable,
java.util.HashMap<TableScanOperator,java.util.Map<java.lang.String,java.lang.String>> topToProps,
java.util.Map<FileSinkOperator,Table> fsopToTable,
java.util.List<LoadTableDesc> loadTableWork,
java.util.List<LoadFileDesc> loadFileWork,
Context ctx,
java.util.HashMap<java.lang.String,java.lang.String> idToTableNameMap,
int destTableId,
UnionProcContext uCtx,
java.util.List<AbstractMapJoinOperator<? extends MapJoinDesc>> listMapJoinOpsNoReducer,
java.util.Map<GroupByOperator,java.util.Set<java.lang.String>> groupOpToInputTables,
java.util.Map<java.lang.String,PrunedPartitionList> prunedPartitions,
java.util.HashMap<TableScanOperator,FilterDesc.sampleDesc> opToSamplePruner,
GlobalLimitCtx globalLimitCtx,
java.util.HashMap<java.lang.String,SplitSample> nameToSplitSample,
java.util.HashSet<ReadEntity> semanticInputs,
java.util.List<Task<? extends java.io.Serializable>> rootTasks,
java.util.Map<TableScanOperator,java.util.Map<java.lang.String,ExprNodeDesc>> opToPartToSkewedPruner,
java.util.Map<java.lang.String,ReadEntity> viewAliasToInput,
java.util.List<ReduceSinkOperator> reduceSinkOperatorsAddedByEnforceBucketingSorting,
QueryProperties queryProperties) |
Modifier and Type | Method and Description |
---|---|
HiveConf |
getConf() |
Context |
getContext() |
int |
getDestTableId() |
ListSinkOperator |
getFetchSink() |
Operator<?> |
getFetchSource() |
TableDesc |
getFetchTabledesc() |
FetchTask |
getFetchTask() |
java.util.Map<FileSinkOperator,Table> |
getFsopToTable() |
GlobalLimitCtx |
getGlobalLimitCtx() |
java.util.Map<GroupByOperator,java.util.Set<java.lang.String>> |
getGroupOpToInputTables() |
java.util.HashMap<java.lang.String,java.lang.String> |
getIdToTableNameMap() |
java.util.Map<JoinOperator,QBJoinTree> |
getJoinContext() |
LineageInfo |
getLineageInfo()
Gets the associated lineage information.
|
java.util.List<AbstractMapJoinOperator<? extends MapJoinDesc>> |
getListMapJoinOpsNoReducer() |
java.util.List<LoadFileDesc> |
getLoadFileWork() |
java.util.List<LoadTableDesc> |
getLoadTableWork() |
java.util.Map<MapJoinOperator,QBJoinTree> |
getMapJoinContext() |
java.util.HashMap<java.lang.String,SplitSample> |
getNameToSplitSample() |
java.util.LinkedHashMap<Operator<? extends OperatorDesc>,OpParseContext> |
getOpParseCtx() |
java.util.HashMap<TableScanOperator,PrunedPartitionList> |
getOpToPartList() |
java.util.HashMap<TableScanOperator,ExprNodeDesc> |
getOpToPartPruner() |
java.util.Map<TableScanOperator,java.util.Map<java.lang.String,ExprNodeDesc>> |
getOpToPartToSkewedPruner() |
java.util.HashMap<TableScanOperator,FilterDesc.sampleDesc> |
getOpToSamplePruner() |
ASTNode |
getParseTree() |
java.util.Map<java.lang.String,PrunedPartitionList> |
getPrunedPartitions() |
PrunedPartitionList |
getPrunedPartitions(java.lang.String alias,
TableScanOperator ts) |
QB |
getQB() |
QueryProperties |
getQueryProperties() |
java.util.List<ReduceSinkOperator> |
getReduceSinkOperatorsAddedByEnforceBucketingSorting() |
java.util.HashSet<ReadEntity> |
getSemanticInputs() |
java.util.Map<SMBMapJoinOperator,QBJoinTree> |
getSmbMapJoinContext() |
java.util.HashMap<java.lang.String,Operator<? extends OperatorDesc>> |
getTopOps() |
java.util.HashMap<java.lang.String,Operator<? extends OperatorDesc>> |
getTopSelOps() |
java.util.HashMap<TableScanOperator,java.util.Map<java.lang.String,java.lang.String>> |
getTopToProps() |
java.util.HashMap<TableScanOperator,Table> |
getTopToTable() |
UnionProcContext |
getUCtx() |
java.util.Map<java.lang.String,ReadEntity> |
getViewAliasToInput() |
OpParseContext |
removeOpParseCtx(Operator<? extends OperatorDesc> op)
Remove the OpParseContext of a specific operator op
|
void |
replaceRootTask(Task<? extends java.io.Serializable> rootTask,
java.util.List<? extends Task<? extends java.io.Serializable>> tasks) |
void |
setConf(HiveConf conf) |
void |
setContext(Context ctx) |
void |
setDestTableId(int destTableId) |
void |
setFetchSink(ListSinkOperator fetchSink) |
void |
setFetchSource(Operator<?> fetchSource) |
void |
setFetchTabledesc(TableDesc fetchTabledesc) |
void |
setFetchTask(FetchTask fetchTask) |
void |
setFsopToTable(java.util.Map<FileSinkOperator,Table> fsopToTable) |
void |
setGlobalLimitCtx(GlobalLimitCtx globalLimitCtx) |
void |
setGroupOpToInputTables(java.util.Map<GroupByOperator,java.util.Set<java.lang.String>> groupOpToInputTables) |
void |
setIdToTableNameMap(java.util.HashMap<java.lang.String,java.lang.String> idToTableNameMap) |
void |
setJoinContext(java.util.Map<JoinOperator,QBJoinTree> joinContext) |
void |
setLineageInfo(LineageInfo lInfo)
Sets the lineage information.
|
void |
setListMapJoinOpsNoReducer(java.util.List<AbstractMapJoinOperator<? extends MapJoinDesc>> listMapJoinOpsNoReducer) |
void |
setLoadFileWork(java.util.List<LoadFileDesc> loadFileWork) |
void |
setLoadTableWork(java.util.List<LoadTableDesc> loadTableWork) |
void |
setMapJoinContext(java.util.Map<MapJoinOperator,QBJoinTree> mapJoinContext) |
void |
setNameToSplitSample(java.util.HashMap<java.lang.String,SplitSample> nameToSplitSample) |
void |
setOpParseCtx(java.util.LinkedHashMap<Operator<? extends OperatorDesc>,OpParseContext> opParseCtx) |
void |
setOpPartToSkewedPruner(java.util.HashMap<TableScanOperator,java.util.Map<java.lang.String,ExprNodeDesc>> opToPartToSkewedPruner) |
void |
setOpToPartList(java.util.HashMap<TableScanOperator,PrunedPartitionList> opToPartList) |
void |
setOpToPartPruner(java.util.HashMap<TableScanOperator,ExprNodeDesc> opToPartPruner) |
void |
setOpToSamplePruner(java.util.HashMap<TableScanOperator,FilterDesc.sampleDesc> opToSamplePruner) |
void |
setParseTree(ASTNode ast) |
void |
setPrunedPartitions(java.util.Map<java.lang.String,PrunedPartitionList> prunedPartitions) |
void |
setQB(QB qb) |
void |
setQueryProperties(QueryProperties queryProperties) |
void |
setReduceSinkOperatorsAddedByEnforceBucketingSorting(java.util.List<ReduceSinkOperator> reduceSinkOperatorsAddedByEnforceBucketingSorting) |
void |
setSmbMapJoinContext(java.util.Map<SMBMapJoinOperator,QBJoinTree> smbMapJoinContext) |
void |
setTopOps(java.util.HashMap<java.lang.String,Operator<? extends OperatorDesc>> topOps) |
void |
setTopSelOps(java.util.HashMap<java.lang.String,Operator<? extends OperatorDesc>> topSelOps) |
void |
setTopToProps(java.util.HashMap<TableScanOperator,java.util.Map<java.lang.String,java.lang.String>> topToProps) |
void |
setTopToTable(java.util.HashMap<TableScanOperator,Table> topToTable) |
void |
setUCtx(UnionProcContext uCtx) |
void |
updateOpParseCtx(Operator<? extends OperatorDesc> op,
OpParseContext newOpParseContext)
Update the OpParseContext of operator op to newOpParseContext.
|
public ParseContext()
public ParseContext(HiveConf conf, QB qb, ASTNode ast, java.util.HashMap<TableScanOperator,ExprNodeDesc> opToPartPruner, java.util.HashMap<TableScanOperator,PrunedPartitionList> opToPartList, java.util.HashMap<java.lang.String,Operator<? extends OperatorDesc>> topOps, java.util.HashMap<java.lang.String,Operator<? extends OperatorDesc>> topSelOps, java.util.LinkedHashMap<Operator<? extends OperatorDesc>,OpParseContext> opParseCtx, java.util.Map<JoinOperator,QBJoinTree> joinContext, java.util.Map<SMBMapJoinOperator,QBJoinTree> smbMapJoinContext, java.util.HashMap<TableScanOperator,Table> topToTable, java.util.HashMap<TableScanOperator,java.util.Map<java.lang.String,java.lang.String>> topToProps, java.util.Map<FileSinkOperator,Table> fsopToTable, java.util.List<LoadTableDesc> loadTableWork, java.util.List<LoadFileDesc> loadFileWork, Context ctx, java.util.HashMap<java.lang.String,java.lang.String> idToTableNameMap, int destTableId, UnionProcContext uCtx, java.util.List<AbstractMapJoinOperator<? extends MapJoinDesc>> listMapJoinOpsNoReducer, java.util.Map<GroupByOperator,java.util.Set<java.lang.String>> groupOpToInputTables, java.util.Map<java.lang.String,PrunedPartitionList> prunedPartitions, java.util.HashMap<TableScanOperator,FilterDesc.sampleDesc> opToSamplePruner, GlobalLimitCtx globalLimitCtx, java.util.HashMap<java.lang.String,SplitSample> nameToSplitSample, java.util.HashSet<ReadEntity> semanticInputs, java.util.List<Task<? extends java.io.Serializable>> rootTasks, java.util.Map<TableScanOperator,java.util.Map<java.lang.String,ExprNodeDesc>> opToPartToSkewedPruner, java.util.Map<java.lang.String,ReadEntity> viewAliasToInput, java.util.List<ReduceSinkOperator> reduceSinkOperatorsAddedByEnforceBucketingSorting, QueryProperties queryProperties)
conf
- qb
- current QBast
- current parse treeopToPartPruner
- map from table scan operator to partition pruneropToPartList
- topOps
- list of operators for the top querytopSelOps
- list of operators for the selects introduced for column pruningopParseCtx
- operator parse context - contains a mapping from operator to
operator parse state (row resolver etc.)joinContext
- context needed join processing (map join specifically)topToTable
- the top tables being processedloadTableWork
- list of destination tables being loadedloadFileWork
- list of destination files being loadedctx
- parse contextidToTableNameMap
- uCtx
- destTableId
- listMapJoinOpsNoReducer
- list of map join operators with no reducergroupOpToInputTables
- prunedPartitions
- opToSamplePruner
- operator to sample pruner mapglobalLimitCtx
- nameToSplitSample
- rootTasks
- public QB getQB()
public void setQB(QB qb)
qb
- the qb to setpublic Context getContext()
public void setContext(Context ctx)
ctx
- the context to setpublic HiveConf getConf()
public void setConf(HiveConf conf)
conf
- the conf to setpublic ASTNode getParseTree()
public void setParseTree(ASTNode ast)
ast
- the parsetree to setpublic java.util.HashMap<TableScanOperator,ExprNodeDesc> getOpToPartPruner()
public void setOpToPartPruner(java.util.HashMap<TableScanOperator,ExprNodeDesc> opToPartPruner)
opToPartPruner
- the opToPartPruner to setpublic java.util.HashMap<TableScanOperator,PrunedPartitionList> getOpToPartList()
public void setOpToPartList(java.util.HashMap<TableScanOperator,PrunedPartitionList> opToPartList)
public java.util.HashMap<TableScanOperator,Table> getTopToTable()
public void setTopToTable(java.util.HashMap<TableScanOperator,Table> topToTable)
topToTable
- the topToTable to setpublic java.util.Map<FileSinkOperator,Table> getFsopToTable()
public void setFsopToTable(java.util.Map<FileSinkOperator,Table> fsopToTable)
public java.util.List<ReduceSinkOperator> getReduceSinkOperatorsAddedByEnforceBucketingSorting()
public void setReduceSinkOperatorsAddedByEnforceBucketingSorting(java.util.List<ReduceSinkOperator> reduceSinkOperatorsAddedByEnforceBucketingSorting)
public java.util.HashMap<TableScanOperator,java.util.Map<java.lang.String,java.lang.String>> getTopToProps()
public void setTopToProps(java.util.HashMap<TableScanOperator,java.util.Map<java.lang.String,java.lang.String>> topToProps)
topToProps
- the topToProps to setpublic java.util.HashMap<java.lang.String,Operator<? extends OperatorDesc>> getTopOps()
public void setTopOps(java.util.HashMap<java.lang.String,Operator<? extends OperatorDesc>> topOps)
topOps
- the topOps to setpublic java.util.HashMap<java.lang.String,Operator<? extends OperatorDesc>> getTopSelOps()
public void setTopSelOps(java.util.HashMap<java.lang.String,Operator<? extends OperatorDesc>> topSelOps)
topSelOps
- the topSelOps to setpublic java.util.LinkedHashMap<Operator<? extends OperatorDesc>,OpParseContext> getOpParseCtx()
public OpParseContext removeOpParseCtx(Operator<? extends OperatorDesc> op)
op
- public void updateOpParseCtx(Operator<? extends OperatorDesc> op, OpParseContext newOpParseContext)
op
- newOpParseContext
- public void setOpParseCtx(java.util.LinkedHashMap<Operator<? extends OperatorDesc>,OpParseContext> opParseCtx)
opParseCtx
- the opParseCtx to setpublic java.util.HashMap<java.lang.String,SplitSample> getNameToSplitSample()
public void setNameToSplitSample(java.util.HashMap<java.lang.String,SplitSample> nameToSplitSample)
public java.util.List<LoadTableDesc> getLoadTableWork()
public void setLoadTableWork(java.util.List<LoadTableDesc> loadTableWork)
loadTableWork
- the loadTableWork to setpublic java.util.List<LoadFileDesc> getLoadFileWork()
public void setLoadFileWork(java.util.List<LoadFileDesc> loadFileWork)
loadFileWork
- the loadFileWork to setpublic java.util.HashMap<java.lang.String,java.lang.String> getIdToTableNameMap()
public void setIdToTableNameMap(java.util.HashMap<java.lang.String,java.lang.String> idToTableNameMap)
public int getDestTableId()
public void setDestTableId(int destTableId)
public UnionProcContext getUCtx()
public void setUCtx(UnionProcContext uCtx)
public java.util.Map<JoinOperator,QBJoinTree> getJoinContext()
public void setJoinContext(java.util.Map<JoinOperator,QBJoinTree> joinContext)
joinContext
- the joinContext to setpublic java.util.List<AbstractMapJoinOperator<? extends MapJoinDesc>> getListMapJoinOpsNoReducer()
public void setListMapJoinOpsNoReducer(java.util.List<AbstractMapJoinOperator<? extends MapJoinDesc>> listMapJoinOpsNoReducer)
listMapJoinOpsNoReducer
- the listMapJoinOpsNoReducer to setpublic java.util.HashMap<TableScanOperator,FilterDesc.sampleDesc> getOpToSamplePruner()
public void setOpToSamplePruner(java.util.HashMap<TableScanOperator,FilterDesc.sampleDesc> opToSamplePruner)
opToSamplePruner
- the opToSamplePruner to setpublic java.util.Map<GroupByOperator,java.util.Set<java.lang.String>> getGroupOpToInputTables()
public void setGroupOpToInputTables(java.util.Map<GroupByOperator,java.util.Set<java.lang.String>> groupOpToInputTables)
groupOpToInputTables
- public java.util.Map<java.lang.String,PrunedPartitionList> getPrunedPartitions()
public void setPrunedPartitions(java.util.Map<java.lang.String,PrunedPartitionList> prunedPartitions)
prunedPartitions
- public void setLineageInfo(LineageInfo lInfo)
lInfo
- The lineage information.public LineageInfo getLineageInfo()
public java.util.Map<MapJoinOperator,QBJoinTree> getMapJoinContext()
public void setMapJoinContext(java.util.Map<MapJoinOperator,QBJoinTree> mapJoinContext)
public java.util.Map<SMBMapJoinOperator,QBJoinTree> getSmbMapJoinContext()
public void setSmbMapJoinContext(java.util.Map<SMBMapJoinOperator,QBJoinTree> smbMapJoinContext)
public GlobalLimitCtx getGlobalLimitCtx()
public void setGlobalLimitCtx(GlobalLimitCtx globalLimitCtx)
public java.util.HashSet<ReadEntity> getSemanticInputs()
public void replaceRootTask(Task<? extends java.io.Serializable> rootTask, java.util.List<? extends Task<? extends java.io.Serializable>> tasks)
public FetchTask getFetchTask()
public void setFetchTask(FetchTask fetchTask)
public PrunedPartitionList getPrunedPartitions(java.lang.String alias, TableScanOperator ts) throws HiveException
HiveException
public java.util.Map<TableScanOperator,java.util.Map<java.lang.String,ExprNodeDesc>> getOpToPartToSkewedPruner()
public void setOpPartToSkewedPruner(java.util.HashMap<TableScanOperator,java.util.Map<java.lang.String,ExprNodeDesc>> opToPartToSkewedPruner)
opToPartToSkewedPruner
- the opToSkewedPruner to setpublic java.util.Map<java.lang.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)
Copyright © 2012 The Apache Software Foundation