org.apache.hadoop.hive.ql.optimizer.physical
Class MapJoinResolver.LocalMapJoinProcCtx

java.lang.Object
  org.apache.hadoop.hive.ql.optimizer.physical.MapJoinResolver.LocalMapJoinProcCtx

All Implemented Interfaces:

NodeProcessorCtx

Enclosing class:

MapJoinResolver

public static class MapJoinResolver.LocalMapJoinProcCtx
extends Object
implements NodeProcessorCtx

A container of current task and parse context.

Constructor Summary

MapJoinResolver.LocalMapJoinProcCtx(Task<? extends Serializable> task, ParseContext parseCtx)

Method Summary

void	addDirectWorks(MapJoinOperator mapJoinOp, List<Operator<? extends OperatorDesc>> directOperators)
void	addDummyParentOp(Operator<? extends OperatorDesc> op)
Task<? extends Serializable>	getCurrentTask()
Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>>	getDirectWorks()
List<Operator<? extends OperatorDesc>>	getDummyParentOp()
ParseContext	getParseCtx()
boolean	isFollowedByGroupBy()
void	setCurrentTask(Task<? extends Serializable> currentTask)
void	setDirectWorks(Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> directWorks)
void	setDummyParentOp(List<Operator<? extends OperatorDesc>> op)
void	setFollowedByGroupBy(boolean isFollowedByGroupBy)
void	setParseCtx(ParseContext parseCtx)

Methods inherited from class java.lang.Object

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

Constructor Detail

MapJoinResolver.LocalMapJoinProcCtx

public MapJoinResolver.LocalMapJoinProcCtx(Task<? extends Serializable> task,
                                           ParseContext parseCtx)

Method Detail

getCurrentTask

public Task<? extends Serializable> getCurrentTask()

setCurrentTask

public void setCurrentTask(Task<? extends Serializable> currentTask)

isFollowedByGroupBy

public boolean isFollowedByGroupBy()

setFollowedByGroupBy

public void setFollowedByGroupBy(boolean isFollowedByGroupBy)

getParseCtx

public ParseContext getParseCtx()

setParseCtx

public void setParseCtx(ParseContext parseCtx)

setDummyParentOp

public void setDummyParentOp(List<Operator<? extends OperatorDesc>> op)

getDummyParentOp

public List<Operator<? extends OperatorDesc>> getDummyParentOp()

addDummyParentOp

public void addDummyParentOp(Operator<? extends OperatorDesc> op)

setDirectWorks

public void setDirectWorks(Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> directWorks)

getDirectWorks

public Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> getDirectWorks()

addDirectWorks

public void addDirectWorks(MapJoinOperator mapJoinOp,
                           List<Operator<? extends OperatorDesc>> directOperators)