public class IntraQueryCorrelation
extends java.lang.Object
Constructor and Description |
---|
IntraQueryCorrelation(int minReducers) |
Modifier and Type | Method and Description |
---|---|
void |
addToAllReduceSinkOperators(ReduceSinkOperator rsop) |
boolean |
adjustNumReducers(int newNumReducers) |
java.util.Set<ReduceSinkOperator> |
getAllReduceSinkOperators() |
java.util.List<ReduceSinkOperator> |
getBottomReduceSinkOperators() |
java.util.Map<java.lang.Integer,java.lang.Integer> |
getNewTagToChildIndex() |
java.util.Map<java.lang.Integer,java.lang.Integer> |
getNewTagToOldTag() |
int |
getNumReducers() |
boolean |
hasJobFlowCorrelation() |
void |
setJobFlowCorrelation(boolean jobFlowCorrelation,
java.util.List<ReduceSinkOperator> bottomReduceSinkOperators) |
void |
setNewTag(java.lang.Integer newTag,
java.lang.Integer oldTag,
java.lang.Integer childIndex) |
public java.util.Map<java.lang.Integer,java.lang.Integer> getNewTagToOldTag()
public java.util.Map<java.lang.Integer,java.lang.Integer> getNewTagToChildIndex()
public void setNewTag(java.lang.Integer newTag, java.lang.Integer oldTag, java.lang.Integer childIndex)
public void addToAllReduceSinkOperators(ReduceSinkOperator rsop)
public java.util.Set<ReduceSinkOperator> getAllReduceSinkOperators()
public void setJobFlowCorrelation(boolean jobFlowCorrelation, java.util.List<ReduceSinkOperator> bottomReduceSinkOperators)
public boolean hasJobFlowCorrelation()
public java.util.List<ReduceSinkOperator> getBottomReduceSinkOperators()
public int getNumReducers()
public boolean adjustNumReducers(int newNumReducers)
Copyright © 2012 The Apache Software Foundation