org.apache.hadoop.hive.ql.plan
Class MapredLocalWork

java.lang.Object
  org.apache.hadoop.hive.ql.plan.MapredLocalWork

All Implemented Interfaces:

Serializable

public class MapredLocalWork
extends Object
implements Serializable

MapredLocalWork.

See Also:

Serialized Form

Constructor Summary

MapredLocalWork()

MapredLocalWork(LinkedHashMap<String,Operator<? extends OperatorDesc>> aliasToWork, LinkedHashMap<String,FetchWork> aliasToFetchWork)

MapredLocalWork(MapredLocalWork clone)

Method Summary

BucketMapJoinContext	copyPartSpecMappingOnly()
void	deriveExplainAttributes()
MapredLocalWork	extractDirectWorks(Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> directWorks)
LinkedHashMap<String,FetchWork>	getAliasToFetchWork()
LinkedHashMap<String,Operator<? extends OperatorDesc>>	getAliasToWork()
String	getBucketFileName(String bigFileName)
BucketMapJoinContext	getBucketMapjoinContext()
BucketMapJoinContext	getBucketMapjoinContextExplain()
Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>>	getDirectFetchOp()
List<Operator<? extends OperatorDesc>>	getDummyParentOp()
boolean	getInputFileChangeSensitive()
String	getStageID()
org.apache.hadoop.fs.Path	getTmpPath()
boolean	hasStagedAlias()
void	setAliasToFetchWork(LinkedHashMap<String,FetchWork> aliasToFetchWork)
void	setAliasToWork(LinkedHashMap<String,Operator<? extends OperatorDesc>> aliasToWork)
void	setBucketMapjoinContext(BucketMapJoinContext bucketMapjoinContext)
void	setDirectFetchOp(Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> op)
void	setDummyParentOp(List<Operator<? extends OperatorDesc>> op)
void	setHasStagedAlias(boolean hasStagedAlias)
void	setInputFileChangeSensitive(boolean inputFileChangeSensitive)
void	setStageID(String stageID)
void	setTmpPath(org.apache.hadoop.fs.Path tmpPath)

Methods inherited from class java.lang.Object

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

Constructor Detail

MapredLocalWork

public MapredLocalWork()

MapredLocalWork

public MapredLocalWork(LinkedHashMap<String,Operator<? extends OperatorDesc>> aliasToWork,
                       LinkedHashMap<String,FetchWork> aliasToFetchWork)

MapredLocalWork

public MapredLocalWork(MapredLocalWork clone)

Method Detail

setDummyParentOp

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

getDummyParentOp

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

getAliasToWork

public LinkedHashMap<String,Operator<? extends OperatorDesc>> getAliasToWork()

getStageID

public String getStageID()

setStageID

public void setStageID(String stageID)

setAliasToWork

public void setAliasToWork(LinkedHashMap<String,Operator<? extends OperatorDesc>> aliasToWork)

getAliasToFetchWork

public LinkedHashMap<String,FetchWork> getAliasToFetchWork()

Returns:

the aliasToFetchWork

setAliasToFetchWork

public void setAliasToFetchWork(LinkedHashMap<String,FetchWork> aliasToFetchWork)

Parameters:

aliasToFetchWork - the aliasToFetchWork to set

getInputFileChangeSensitive

public boolean getInputFileChangeSensitive()

setInputFileChangeSensitive

public void setInputFileChangeSensitive(boolean inputFileChangeSensitive)

deriveExplainAttributes

public void deriveExplainAttributes()

getBucketMapjoinContextExplain

public BucketMapJoinContext getBucketMapjoinContextExplain()

getBucketMapjoinContext

public BucketMapJoinContext getBucketMapjoinContext()

setBucketMapjoinContext

public void setBucketMapjoinContext(BucketMapJoinContext bucketMapjoinContext)

copyPartSpecMappingOnly

public BucketMapJoinContext copyPartSpecMappingOnly()

setTmpPath

public void setTmpPath(org.apache.hadoop.fs.Path tmpPath)

getTmpPath

public org.apache.hadoop.fs.Path getTmpPath()

getBucketFileName

public String getBucketFileName(String bigFileName)

extractDirectWorks

public MapredLocalWork extractDirectWorks(Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> directWorks)

setDirectFetchOp

public void setDirectFetchOp(Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> op)

getDirectFetchOp

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

hasStagedAlias

public boolean hasStagedAlias()

setHasStagedAlias

public void setHasStagedAlias(boolean hasStagedAlias)