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

Constructors

Constructor and Description
MapredLocalWork()
MapredLocalWork(LinkedHashMap<String,Operator<? extends OperatorDesc>> aliasToWork, LinkedHashMap<String,FetchWork> aliasToFetchWork)
MapredLocalWork(MapredLocalWork clone)

Method Summary

Methods

Modifier and Type	Method and Description
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	getTmpHDFSPath()
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	setTmpHDFSPath(org.apache.hadoop.fs.Path tmpPath)
void	setTmpPath(org.apache.hadoop.fs.Path tmpPath)

Methods inherited from class java.lang.Object

clone, equals, finalize, 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()

setTmpHDFSPath

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

getTmpHDFSPath

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

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)