protected class CorrelationOptimizer.CorrelationNodeProcCtx
extends java.lang.Object
Constructor and Description |
---|
CorrelationNodeProcCtx(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
void |
addCorrelation(IntraQueryCorrelation correlation) |
boolean |
addRemovedOperator(Operator<?> rsOp) |
void |
addWalked(ReduceSinkOperator op) |
void |
addWalkedAll(java.util.Collection<ReduceSinkOperator> c) |
java.util.List<java.lang.String> |
getAbortReasons() |
java.util.List<IntraQueryCorrelation> |
getCorrelations() |
ParseContext |
getPctx() |
boolean |
hasBeenRemoved(Operator<?> rsOp) |
void |
incrementFileSinkOperatorCount() |
boolean |
isAbort() |
boolean |
isWalked(ReduceSinkOperator op) |
int |
minReducer() |
void |
removeWalked(ReduceSinkOperator op) |
void |
removeWalkedAll(java.util.Collection<ReduceSinkOperator> c) |
void |
setAbort(boolean abort) |
void |
setPctx(ParseContext pctx) |
boolean |
trustScript() |
public CorrelationNodeProcCtx(ParseContext pctx)
public void setAbort(boolean abort)
public boolean isAbort()
public java.util.List<java.lang.String> getAbortReasons()
public void addCorrelation(IntraQueryCorrelation correlation)
public java.util.List<IntraQueryCorrelation> getCorrelations()
public boolean isWalked(ReduceSinkOperator op)
public void addWalked(ReduceSinkOperator op)
public void addWalkedAll(java.util.Collection<ReduceSinkOperator> c)
public void removeWalked(ReduceSinkOperator op)
public void removeWalkedAll(java.util.Collection<ReduceSinkOperator> c)
public void incrementFileSinkOperatorCount()
public ParseContext getPctx()
public void setPctx(ParseContext pctx)
public boolean trustScript()
public int minReducer()
public boolean hasBeenRemoved(Operator<?> rsOp)
public boolean addRemovedOperator(Operator<?> rsOp)
Copyright © 2012 The Apache Software Foundation