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

java.lang.Object
  org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc
      org.apache.hadoop.hive.ql.plan.ReduceSinkDesc

All Implemented Interfaces:

Serializable, Cloneable, OperatorDesc

public class ReduceSinkDesc
extends AbstractOperatorDesc

ReduceSinkDesc.

See Also:

Serialized Form

Constructor Summary

ReduceSinkDesc()

ReduceSinkDesc(ArrayList<ExprNodeDesc> keyCols, int numDistributionKeys, ArrayList<ExprNodeDesc> valueCols, ArrayList<String> outputKeyColumnNames, List<List<Integer>> distinctColumnIndices, ArrayList<String> outputValueColumnNames, int tag, ArrayList<ExprNodeDesc> partitionCols, int numReducers, TableDesc keySerializeInfo, TableDesc valueSerializeInfo)

Method Summary

Object	clone()
List<ExprNodeDesc>	getBucketCols()
List<List<Integer>>	getDistinctColumnIndices()
ArrayList<ExprNodeDesc>	getKeyCols()
String	getKeyColString()
TableDesc	getKeySerializeInfo()
int	getNumBuckets()
int	getNumDistributionKeys()
int	getNumReducers() Returns the number of reducers for the map-reduce job.
String	getOrder() Returns the sort order of the key columns.
ArrayList<String>	getOutputKeyColumnNames()
String	getOutputName()
ArrayList<String>	getOutputValueColumnNames()
String	getParitionColsString()
ArrayList<ExprNodeDesc>	getPartitionCols()
int	getTag()
int	getTopN()
Integer	getTopNExplain()
float	getTopNMemoryUsage()
Float	getTopNMemoryUsageExplain()
ArrayList<ExprNodeDesc>	getValueCols()
String	getValueColsString()
TableDesc	getValueSerializeInfo()
boolean	isMapGroupBy()
void	setBucketCols(List<ExprNodeDesc> bucketCols)
void	setDistinctColumnIndices(List<List<Integer>> distinctColumnIndices)
void	setKeyCols(ArrayList<ExprNodeDesc> keyCols)
void	setKeySerializeInfo(TableDesc keySerializeInfo)
void	setMapGroupBy(boolean mapGroupBy)
void	setNumBuckets(int numBuckets)
void	setNumDistributionKeys(int numKeys)
void	setNumReducers(int numReducers)
void	setOrder(String orderStr)
void	setOutputKeyColumnNames(ArrayList<String> outputKeyColumnNames)
void	setOutputName(String outputName)
void	setOutputValueColumnNames(ArrayList<String> outputValueColumnNames)
void	setPartitionCols(ArrayList<ExprNodeDesc> partitionCols)
void	setTag(int tag)
void	setTopN(int topN)
void	setTopNMemoryUsage(float topNMemoryUsage)
void	setValueCols(ArrayList<ExprNodeDesc> valueCols)
void	setValueSerializeInfo(TableDesc valueSerializeInfo)

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

getOpTraits, getStatistics, setOpTraits, setStatistics, setVectorMode

Methods inherited from class java.lang.Object

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

Constructor Detail

ReduceSinkDesc

public ReduceSinkDesc()

ReduceSinkDesc

public ReduceSinkDesc(ArrayList<ExprNodeDesc> keyCols,
                      int numDistributionKeys,
                      ArrayList<ExprNodeDesc> valueCols,
                      ArrayList<String> outputKeyColumnNames,
                      List<List<Integer>> distinctColumnIndices,
                      ArrayList<String> outputValueColumnNames,
                      int tag,
                      ArrayList<ExprNodeDesc> partitionCols,
                      int numReducers,
                      TableDesc keySerializeInfo,
                      TableDesc valueSerializeInfo)

Method Detail

clone

public Object clone()

Specified by:

clone in interface OperatorDesc

Overrides:

clone in class AbstractOperatorDesc

getOutputKeyColumnNames

public ArrayList<String> getOutputKeyColumnNames()

setOutputKeyColumnNames

public void setOutputKeyColumnNames(ArrayList<String> outputKeyColumnNames)

getOutputValueColumnNames

public ArrayList<String> getOutputValueColumnNames()

setOutputValueColumnNames

public void setOutputValueColumnNames(ArrayList<String> outputValueColumnNames)

getKeyColString

public String getKeyColString()

getKeyCols

public ArrayList<ExprNodeDesc> getKeyCols()

setKeyCols

public void setKeyCols(ArrayList<ExprNodeDesc> keyCols)

getNumDistributionKeys

public int getNumDistributionKeys()

setNumDistributionKeys

public void setNumDistributionKeys(int numKeys)

getValueColsString

public String getValueColsString()

getValueCols

public ArrayList<ExprNodeDesc> getValueCols()

setValueCols

public void setValueCols(ArrayList<ExprNodeDesc> valueCols)

getParitionColsString

public String getParitionColsString()

getPartitionCols

public ArrayList<ExprNodeDesc> getPartitionCols()

setPartitionCols

public void setPartitionCols(ArrayList<ExprNodeDesc> partitionCols)

getTag

public int getTag()

setTag

public void setTag(int tag)

getTopN

public int getTopN()

setTopN

public void setTopN(int topN)

getTopNExplain

public Integer getTopNExplain()

getTopNMemoryUsage

public float getTopNMemoryUsage()

setTopNMemoryUsage

public void setTopNMemoryUsage(float topNMemoryUsage)

getTopNMemoryUsageExplain

public Float getTopNMemoryUsageExplain()

isMapGroupBy

public boolean isMapGroupBy()

setMapGroupBy

public void setMapGroupBy(boolean mapGroupBy)

getNumReducers

public int getNumReducers()

Returns the number of reducers for the map-reduce job. -1 means to decide the number of reducers at runtime. This enables Hive to estimate the number of reducers based on the map-reduce input data size, which is only available right before we start the map-reduce job.

setNumReducers

public void setNumReducers(int numReducers)

getKeySerializeInfo

public TableDesc getKeySerializeInfo()

setKeySerializeInfo

public void setKeySerializeInfo(TableDesc keySerializeInfo)

getValueSerializeInfo

public TableDesc getValueSerializeInfo()

setValueSerializeInfo

public void setValueSerializeInfo(TableDesc valueSerializeInfo)

getOrder

public String getOrder()

Returns the sort order of the key columns.

Returns:

null, which means ascending order for all key columns, or a String of the same length as key columns, that consists of only "+" (ascending order) and "-" (descending order).

setOrder

public void setOrder(String orderStr)

getDistinctColumnIndices

public List<List<Integer>> getDistinctColumnIndices()

setDistinctColumnIndices

public void setDistinctColumnIndices(List<List<Integer>> distinctColumnIndices)

getOutputName

public String getOutputName()

setOutputName

public void setOutputName(String outputName)

getNumBuckets

public int getNumBuckets()

setNumBuckets

public void setNumBuckets(int numBuckets)

getBucketCols

public List<ExprNodeDesc> getBucketCols()

setBucketCols

public void setBucketCols(List<ExprNodeDesc> bucketCols)