org.apache.hadoop.hive.ql.plan

Class BaseWork

java.lang.Object

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

org.apache.hadoop.hive.ql.plan.BaseWork

All Implemented Interfaces:

Serializable, Cloneable, OperatorDesc

Direct Known Subclasses:

MapWork, MergeJoinWork, ReduceWork, UnionWork

public abstract class BaseWork
extends AbstractOperatorDesc

BaseWork. Base class for any "work" that's being done on the cluster. Items like stats gathering that are commonly used regardless of the type of work live here.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,Integer>	vectorColumnNameMap
protected Map<Integer,String>	vectorColumnTypeMap
protected Map<Integer,String>	vectorScratchColumnTypeMap

Fields inherited from class org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

opProps, opTraits, statistics, vectorMode

Constructor Summary

Constructors

Constructor and Description
BaseWork()
BaseWork(String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	addDummyOp(HashTableDummyOperator dummyOp)
void	addSortCols(List<String> sortCols)
abstract void	configureJobConf(org.apache.hadoop.mapred.JobConf job)
Set<Operator<?>>	getAllLeafOperators() Returns a set containing all leaf operators from the operator tree in this work.
Set<Operator<?>>	getAllOperators()
abstract Set<Operator<?>>	getAllRootOperators()
List<HashTableDummyOperator>	getDummyOps()
MapredLocalWork	getMapRedLocalWork()
String	getName()
List<String>	getSortCols()
int	getTag()
Map<String,Integer>	getVectorColumnNameMap()
Map<Integer,String>	getVectorColumnTypeMap()
Map<Integer,String>	getVectorScratchColumnTypeMap()
boolean	isGatheringStats()
abstract void	replaceRoots(Map<Operator<?>,Operator<?>> replacementMap)
void	setDummyOps(List<HashTableDummyOperator> dummyOps)
void	setGatheringStats(boolean gatherStats)
void	setMapRedLocalWork(MapredLocalWork mapLocalWork)
void	setName(String name)
void	setTag(int tag)
void	setVectorColumnNameMap(Map<String,Integer> vectorColumnNameMap)
void	setVectorColumnTypeMap(Map<Integer,String> vectorColumnTypeMap)
void	setVectorScratchColumnTypeMap(Map<Integer,String> vectorScratchColumnTypeMap)

Methods inherited from class org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

clone, getOpProps, getStatistics, getTraits, getVectorMode, setOpProps, setStatistics, setTraits, setVectorMode

Methods inherited from class java.lang.Object

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

Field Detail

vectorColumnNameMap

protected Map<String,Integer> vectorColumnNameMap

vectorColumnTypeMap

protected Map<Integer,String> vectorColumnTypeMap

vectorScratchColumnTypeMap

protected Map<Integer,String> vectorScratchColumnTypeMap

Constructor Detail

BaseWork

public BaseWork()

BaseWork

public BaseWork(String name)

Method Detail

setGatheringStats

public void setGatheringStats(boolean gatherStats)

isGatheringStats

public boolean isGatheringStats()

getName

public String getName()

setName

public void setName(String name)

getDummyOps

public List<HashTableDummyOperator> getDummyOps()

setDummyOps

public void setDummyOps(List<HashTableDummyOperator> dummyOps)

addDummyOp

public void addDummyOp(HashTableDummyOperator dummyOp)

replaceRoots

public abstract void replaceRoots(Map<Operator<?>,Operator<?>> replacementMap)

getAllRootOperators

public abstract Set<Operator<?>> getAllRootOperators()

getAllOperators

public Set<Operator<?>> getAllOperators()

getAllLeafOperators

public Set<Operator<?>> getAllLeafOperators()

Returns a set containing all leaf operators from the operator tree in this work.

Returns:

a set containing all leaf operators in this operator tree.

getVectorColumnNameMap

public Map<String,Integer> getVectorColumnNameMap()

setVectorColumnNameMap

public void setVectorColumnNameMap(Map<String,Integer> vectorColumnNameMap)

getVectorColumnTypeMap

public Map<Integer,String> getVectorColumnTypeMap()

setVectorColumnTypeMap

public void setVectorColumnTypeMap(Map<Integer,String> vectorColumnTypeMap)

getVectorScratchColumnTypeMap

public Map<Integer,String> getVectorScratchColumnTypeMap()

setVectorScratchColumnTypeMap

public void setVectorScratchColumnTypeMap(Map<Integer,String> vectorScratchColumnTypeMap)

getMapRedLocalWork

public MapredLocalWork getMapRedLocalWork()

Returns:

the mapredLocalWork

setMapRedLocalWork

public void setMapRedLocalWork(MapredLocalWork mapLocalWork)

Parameters:

mapLocalWork - the mapredLocalWork to set

configureJobConf

public abstract void configureJobConf(org.apache.hadoop.mapred.JobConf job)

setTag

public void setTag(int tag)

getTag

public int getTag()

addSortCols

public void addSortCols(List<String> sortCols)

getSortCols

public List<String> getSortCols()