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

Class ReduceSinkDeDuplication.ReduceSinkDeduplicateProcCtx

java.lang.Object

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

All Implemented Interfaces:

NodeProcessorCtx

Enclosing class:

ReduceSinkDeDuplication

protected class ReduceSinkDeDuplication.ReduceSinkDeduplicateProcCtx
extends Object

Constructor Summary

Constructors

Constructor and Description
ReduceSinkDeduplicateProcCtx(ParseContext pctx)

Method Summary

Modifier and Type	Method and Description
boolean	addRemovedOperator(Operator<?> rsOp)
ParseContext	getPctx()
boolean	hasBeenRemoved(Operator<?> rsOp)
boolean	isMapAggr()
int	minReducer()
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

ReduceSinkDeduplicateProcCtx

public ReduceSinkDeduplicateProcCtx(ParseContext pctx)

Method Detail

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)

isMapAggr

public boolean isMapAggr()