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
ReduceSinkDeDuplication.ReduceSinkDeduplicateProcCtx(ParseContext pctx)

Method Summary

Methods

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

ReduceSinkDeDuplication.ReduceSinkDeduplicateProcCtx

public ReduceSinkDeDuplication.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)