org.apache.hadoop.hive.ql.optimizer.correlation
Class IntraQueryCorrelation

java.lang.Object
  org.apache.hadoop.hive.ql.optimizer.correlation.IntraQueryCorrelation

public class IntraQueryCorrelation
extends Object

IntraQueryCorrelation records a sub-tree of the query plan tree which can be evaluated in a single MR job. The boundary of this sub-tree is recorded by the ReduceSinkOperators the the bottom of this sub-tree. Also, allReduceSinkOperators in IntraQueryCorrelation contains all ReduceSinkOperators of this sub-tree.

Constructor Summary

IntraQueryCorrelation(int minReducers)

Method Summary

void	addToAllReduceSinkOperators(ReduceSinkOperator rsop)
boolean	adjustNumReducers(int newNumReducers)
Set<ReduceSinkOperator>	getAllReduceSinkOperators()
List<ReduceSinkOperator>	getBottomReduceSinkOperators()
Map<Integer,Integer>	getNewTagToChildIndex()
Map<Integer,Integer>	getNewTagToOldTag()
int	getNumReducers()
boolean	hasJobFlowCorrelation()
void	setJobFlowCorrelation(boolean jobFlowCorrelation, List<ReduceSinkOperator> bottomReduceSinkOperators)
void	setNewTag(Integer newTag, Integer oldTag, Integer childIndex)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IntraQueryCorrelation

public IntraQueryCorrelation(int minReducers)

Method Detail

getNewTagToOldTag

public Map<Integer,Integer> getNewTagToOldTag()

getNewTagToChildIndex

public Map<Integer,Integer> getNewTagToChildIndex()

setNewTag

public void setNewTag(Integer newTag,
                      Integer oldTag,
                      Integer childIndex)

addToAllReduceSinkOperators

public void addToAllReduceSinkOperators(ReduceSinkOperator rsop)

getAllReduceSinkOperators

public Set<ReduceSinkOperator> getAllReduceSinkOperators()

setJobFlowCorrelation

public void setJobFlowCorrelation(boolean jobFlowCorrelation,
                                  List<ReduceSinkOperator> bottomReduceSinkOperators)

hasJobFlowCorrelation

public boolean hasJobFlowCorrelation()

getBottomReduceSinkOperators

public List<ReduceSinkOperator> getBottomReduceSinkOperators()

getNumReducers

public int getNumReducers()

adjustNumReducers

public boolean adjustNumReducers(int newNumReducers)