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

Class CorrelationOptimizer.CorrelationNodeProcCtx

java.lang.Object

org.apache.hadoop.hive.ql.optimizer.correlation.CorrelationOptimizer.CorrelationNodeProcCtx

All Implemented Interfaces:

NodeProcessorCtx

Enclosing class:

CorrelationOptimizer

protected class CorrelationOptimizer.CorrelationNodeProcCtx
extends Object

Constructor Summary

Constructors

Constructor and Description
CorrelationOptimizer.CorrelationNodeProcCtx(ParseContext pctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	addCorrelation(IntraQueryCorrelation correlation)
boolean	addRemovedOperator(Operator<?> rsOp)
void	addWalked(ReduceSinkOperator op)
void	addWalkedAll(Collection<ReduceSinkOperator> c)
List<String>	getAbortReasons()
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(Collection<ReduceSinkOperator> c)
void	setAbort(boolean abort)
void	setPctx(ParseContext pctx)
boolean	trustScript()

Methods inherited from class java.lang.Object

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

Constructor Detail

CorrelationOptimizer.CorrelationNodeProcCtx

public CorrelationOptimizer.CorrelationNodeProcCtx(ParseContext pctx)

Method Detail

setAbort

public void setAbort(boolean abort)

isAbort

public boolean isAbort()

getAbortReasons

public List<String> getAbortReasons()

addCorrelation

public void addCorrelation(IntraQueryCorrelation correlation)

getCorrelations

public List<IntraQueryCorrelation> getCorrelations()

isWalked

public boolean isWalked(ReduceSinkOperator op)

addWalked

public void addWalked(ReduceSinkOperator op)

addWalkedAll

public void addWalkedAll(Collection<ReduceSinkOperator> c)

removeWalked

public void removeWalked(ReduceSinkOperator op)

removeWalkedAll

public void removeWalkedAll(Collection<ReduceSinkOperator> c)

incrementFileSinkOperatorCount

public void incrementFileSinkOperatorCount()

getPctx

public ParseContext getPctx()

setPctx

public void setPctx(ParseContext pctx)

trustScript

public boolean trustScript()

minReducer

public int minReducer()

hasBeenRemoved

public boolean hasBeenRemoved(Operator<?> rsOp)

addRemovedOperator

public boolean addRemovedOperator(Operator<?> rsOp)