org.apache.hadoop.hive.ql.plan

Class AbstractOperatorDesc

java.lang.Object

org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

All Implemented Interfaces:

Serializable, Cloneable, OperatorDesc

Direct Known Subclasses:

AppMasterEventDesc, BaseWork, CollectDesc, DemuxDesc, DummyStoreDesc, FileMergeDesc, FileSinkDesc, FilterDesc, ForwardDesc, GroupByDesc, HashTableDummyDesc, JoinDesc, LateralViewForwardDesc, LateralViewJoinDesc, LimitDesc, ListSinkDesc, MapredWork, MuxDesc, PTFDesc, ReduceSinkDesc, ScriptDesc, SelectDesc, SparkPartitionPruningSinkDesc, SparkWork, TableScanDesc, TezWork, UDTFDesc, UnionDesc

public abstract class AbstractOperatorDesc
extends Object
implements OperatorDesc

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,ExprNodeDesc>	colExprMap A map of output column name to input expression map.
protected long	memAvailable
protected long	memNeeded
protected Map<String,String>	opProps
protected OpTraits	opTraits
protected String	runtimeStatsTmpDir
protected Statistics	statistics
protected VectorDesc	vectorDesc
protected boolean	vectorMode

Constructor Summary

Constructors

Constructor and Description
AbstractOperatorDesc()

Method Summary

Modifier and Type	Method and Description
Object	clone()
void	fillSignature(Map<String,Object> ret)
Map<String,ExprNodeDesc>	getColumnExprMap()
Map<String,String>	getColumnExprMapForExplain()
long	getMaxMemoryAvailable()
long	getMemoryNeeded()
Map<String,String>	getOpProps()
String	getRuntimeStatsTmpDir()
Statistics	getStatistics()
OpTraits	getTraits()
String	getUserLevelStatistics()
VectorDesc	getVectorDesc()
boolean	getVectorMode()
boolean	isSame(OperatorDesc other) The default implementation delegates to Object.equals(Object).
void	setColumnExprMap(Map<String,ExprNodeDesc> colExprMap)
void	setMaxMemoryAvailable(long memoryAvailble)
void	setMemoryNeeded(long memNeeded)
void	setOpProps(Map<String,String> props)
void	setRuntimeStatsTmpDir(String runtimeStatsTmpDir)
void	setStatistics(Statistics statistics)
void	setTraits(OpTraits opTraits)
void	setVectorDesc(VectorDesc vectorDesc)
void	setVectorMode(boolean vm)

Methods inherited from class java.lang.Object

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

Field Detail

vectorMode

protected boolean vectorMode

vectorDesc

protected VectorDesc vectorDesc

statistics

protected Statistics statistics

opTraits

protected transient OpTraits opTraits

opProps

protected transient Map<String,String> opProps

memNeeded

protected long memNeeded

memAvailable

protected long memAvailable

runtimeStatsTmpDir

protected String runtimeStatsTmpDir

colExprMap

protected Map<String,ExprNodeDesc> colExprMap

A map of output column name to input expression map. This is used by optimizer and built during semantic analysis contains only key elements for reduce sink and group by op

Constructor Detail

AbstractOperatorDesc

public AbstractOperatorDesc()

Method Detail

getStatistics

public Statistics getStatistics()

Specified by:

getStatistics in interface OperatorDesc

getUserLevelStatistics

public String getUserLevelStatistics()

setStatistics

public void setStatistics(Statistics statistics)

Specified by:

setStatistics in interface OperatorDesc

clone

public Object clone()
             throws CloneNotSupportedException

Specified by:

clone in interface OperatorDesc

Overrides:

clone in class Object

Throws:

CloneNotSupportedException

getVectorMode

public boolean getVectorMode()

setVectorMode

public void setVectorMode(boolean vm)

setVectorDesc

public void setVectorDesc(VectorDesc vectorDesc)

getVectorDesc

public VectorDesc getVectorDesc()

getTraits

public OpTraits getTraits()

Specified by:

getTraits in interface OperatorDesc

setTraits

public void setTraits(OpTraits opTraits)

Specified by:

setTraits in interface OperatorDesc

getOpProps

public Map<String,String> getOpProps()

Specified by:

getOpProps in interface OperatorDesc

setOpProps

public void setOpProps(Map<String,String> props)

getMemoryNeeded

public long getMemoryNeeded()

Specified by:

getMemoryNeeded in interface OperatorDesc

setMemoryNeeded

public void setMemoryNeeded(long memNeeded)

Specified by:

setMemoryNeeded in interface OperatorDesc

getMaxMemoryAvailable

public long getMaxMemoryAvailable()

Specified by:

getMaxMemoryAvailable in interface OperatorDesc

setMaxMemoryAvailable

public void setMaxMemoryAvailable(long memoryAvailble)

Specified by:

setMaxMemoryAvailable in interface OperatorDesc

getRuntimeStatsTmpDir

public String getRuntimeStatsTmpDir()

Specified by:

getRuntimeStatsTmpDir in interface OperatorDesc

setRuntimeStatsTmpDir

public void setRuntimeStatsTmpDir(String runtimeStatsTmpDir)

Specified by:

setRuntimeStatsTmpDir in interface OperatorDesc

isSame

public boolean isSame(OperatorDesc other)

The default implementation delegates to Object.equals(Object). Intended to be overridden by sub classes.

Specified by:

isSame in interface OperatorDesc

getColumnExprMapForExplain

public Map<String,String> getColumnExprMapForExplain()

getColumnExprMap

public Map<String,ExprNodeDesc> getColumnExprMap()

Specified by:

getColumnExprMap in interface OperatorDesc

setColumnExprMap

public void setColumnExprMap(Map<String,ExprNodeDesc> colExprMap)

Specified by:

setColumnExprMap in interface OperatorDesc

fillSignature

public void fillSignature(Map<String,Object> ret)

Specified by:

fillSignature in interface OperatorDesc