public class GenMRProcContext extends java.lang.Object implements NodeProcessorCtx
Modifier and Type | Class and Description |
---|---|
static class |
GenMRProcContext.GenMapRedCtx
GenMapRedCtx is used to keep track of the current state.
|
static class |
GenMRProcContext.GenMRUnionCtx
GenMRUnionCtx.
|
Constructor and Description |
---|
GenMRProcContext() |
GenMRProcContext(HiveConf conf,
java.util.HashMap<Operator<? extends OperatorDesc>,Task<? extends java.io.Serializable>> opTaskMap,
ParseContext parseCtx,
java.util.List<Task<MoveWork>> mvTask,
java.util.List<Task<? extends java.io.Serializable>> rootTasks,
java.util.LinkedHashMap<Operator<? extends OperatorDesc>,GenMRProcContext.GenMapRedCtx> mapCurrCtx,
java.util.Set<ReadEntity> inputs,
java.util.Set<WriteEntity> outputs) |
Modifier and Type | Method and Description |
---|---|
boolean |
addRootIfPossible(Task<? extends java.io.Serializable> task) |
void |
addSeenOp(Task task,
Operator operator) |
HiveConf |
getConf() |
java.lang.String |
getCurrAliasId() |
Task<? extends java.io.Serializable> |
getCurrTask() |
Operator<? extends OperatorDesc> |
getCurrTopOp() |
UnionOperator |
getCurrUnionOp() |
DependencyCollectionTask |
getDependencyTaskForMultiInsert()
Returns dependencyTaskForMultiInsert initializing it if necessary.
|
java.util.Set<ReadEntity> |
getInputs()
Get the input set.
|
java.util.Map<FileSinkDesc,Task<? extends java.io.Serializable>> |
getLinkedFileDescTasks() |
java.util.LinkedHashMap<Operator<? extends OperatorDesc>,GenMRProcContext.GenMapRedCtx> |
getMapCurrCtx() |
java.util.List<Task<MoveWork>> |
getMvTask() |
java.util.HashMap<Operator<? extends OperatorDesc>,Task<? extends java.io.Serializable>> |
getOpTaskMap() |
java.util.Set<WriteEntity> |
getOutputs()
Get the output set.
|
ParseContext |
getParseCtx() |
java.util.List<Task<? extends java.io.Serializable>> |
getRootTasks() |
java.util.List<FileSinkOperator> |
getSeenFileSinkOps() |
GenMRProcContext.GenMRUnionCtx |
getUnionTask(UnionOperator op) |
boolean |
isSeenOp(Task task,
Operator operator) |
void |
setConf(HiveConf conf) |
void |
setCurrAliasId(java.lang.String currAliasId) |
void |
setCurrTask(Task<? extends java.io.Serializable> currTask) |
void |
setCurrTopOp(Operator<? extends OperatorDesc> currTopOp) |
void |
setCurrUnionOp(UnionOperator currUnionOp) |
void |
setLinkedFileDescTasks(java.util.Map<FileSinkDesc,Task<? extends java.io.Serializable>> linkedFileDescTasks) |
void |
setMapCurrCtx(java.util.LinkedHashMap<Operator<? extends OperatorDesc>,GenMRProcContext.GenMapRedCtx> mapCurrCtx) |
void |
setMvTask(java.util.List<Task<MoveWork>> mvTask) |
void |
setOpTaskMap(java.util.HashMap<Operator<? extends OperatorDesc>,Task<? extends java.io.Serializable>> opTaskMap) |
void |
setParseCtx(ParseContext parseCtx) |
void |
setRootTasks(java.util.List<Task<? extends java.io.Serializable>> rootTasks) |
void |
setSeenFileSinkOps(java.util.List<FileSinkOperator> seenFileSinkOps) |
void |
setUnionTask(UnionOperator op,
GenMRProcContext.GenMRUnionCtx uTask) |
public GenMRProcContext()
public GenMRProcContext(HiveConf conf, java.util.HashMap<Operator<? extends OperatorDesc>,Task<? extends java.io.Serializable>> opTaskMap, ParseContext parseCtx, java.util.List<Task<MoveWork>> mvTask, java.util.List<Task<? extends java.io.Serializable>> rootTasks, java.util.LinkedHashMap<Operator<? extends OperatorDesc>,GenMRProcContext.GenMapRedCtx> mapCurrCtx, java.util.Set<ReadEntity> inputs, java.util.Set<WriteEntity> outputs)
conf
- hive configurationopTaskMap
- reducer to task mappingseenOps
- operator already visitedparseCtx
- current parse contextrootTasks
- root tasks for the planmvTask
- the final move taskmapCurrCtx
- operator to task mappingsinputs
- the set of input tables/partitions generated by the walkoutputs
- the set of destinations generated by the walkpublic java.util.HashMap<Operator<? extends OperatorDesc>,Task<? extends java.io.Serializable>> getOpTaskMap()
public void setOpTaskMap(java.util.HashMap<Operator<? extends OperatorDesc>,Task<? extends java.io.Serializable>> opTaskMap)
opTaskMap
- reducer to task mappingpublic java.util.List<FileSinkOperator> getSeenFileSinkOps()
public void setSeenFileSinkOps(java.util.List<FileSinkOperator> seenFileSinkOps)
seenFileSinkOps
- file sink operators already visitedpublic ParseContext getParseCtx()
public void setParseCtx(ParseContext parseCtx)
parseCtx
- current parse contextpublic void setMvTask(java.util.List<Task<MoveWork>> mvTask)
mvTask
- the final move taskpublic java.util.List<Task<? extends java.io.Serializable>> getRootTasks()
public void setRootTasks(java.util.List<Task<? extends java.io.Serializable>> rootTasks)
rootTasks
- root tasks for the planpublic boolean addRootIfPossible(Task<? extends java.io.Serializable> task)
public java.util.LinkedHashMap<Operator<? extends OperatorDesc>,GenMRProcContext.GenMapRedCtx> getMapCurrCtx()
public void setMapCurrCtx(java.util.LinkedHashMap<Operator<? extends OperatorDesc>,GenMRProcContext.GenMapRedCtx> mapCurrCtx)
mapCurrCtx
- operator to task mappingspublic Task<? extends java.io.Serializable> getCurrTask()
public void setCurrTask(Task<? extends java.io.Serializable> currTask)
currTask
- current taskpublic Operator<? extends OperatorDesc> getCurrTopOp()
public void setCurrTopOp(Operator<? extends OperatorDesc> currTopOp)
currTopOp
- current top operatorpublic UnionOperator getCurrUnionOp()
public void setCurrUnionOp(UnionOperator currUnionOp)
currUnionOp
- current union operatorpublic java.lang.String getCurrAliasId()
public void setCurrAliasId(java.lang.String currAliasId)
currAliasId
- current top aliaspublic GenMRProcContext.GenMRUnionCtx getUnionTask(UnionOperator op)
public void setUnionTask(UnionOperator op, GenMRProcContext.GenMRUnionCtx uTask)
public java.util.Set<ReadEntity> getInputs()
public java.util.Set<WriteEntity> getOutputs()
public HiveConf getConf()
public void setConf(HiveConf conf)
conf
- the conf to setpublic DependencyCollectionTask getDependencyTaskForMultiInsert()
public java.util.Map<FileSinkDesc,Task<? extends java.io.Serializable>> getLinkedFileDescTasks()
public void setLinkedFileDescTasks(java.util.Map<FileSinkDesc,Task<? extends java.io.Serializable>> linkedFileDescTasks)
Copyright © 2012 The Apache Software Foundation