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<List<Integer>>	getDistinctColumnIndices()
ArrayList<ExprNodeDesc>	getKeyCols()
TableDesc	getKeySerializeInfo()
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()
ArrayList<String>	getOutputValueColumnNames()
ArrayList<ExprNodeDesc>	getPartitionCols()
int	getTag()
ArrayList<ExprNodeDesc>	getValueCols()
TableDesc	getValueSerializeInfo()
void	setDistinctColumnIndices(List<List<Integer>> distinctColumnIndices)
void	setKeyCols(ArrayList<ExprNodeDesc> keyCols)
void	setKeySerializeInfo(TableDesc keySerializeInfo)
void	setNumDistributionKeys(int numKeys)
void	setNumReducers(int numReducers)
void	setOrder(String orderStr)
void	setOutputKeyColumnNames(ArrayList<String> outputKeyColumnNames)
void	setOutputValueColumnNames(ArrayList<String> outputValueColumnNames)
void	setPartitionCols(ArrayList<ExprNodeDesc> partitionCols)
void	setTag(int tag)
void	setValueCols(ArrayList<ExprNodeDesc> valueCols)
void	setValueSerializeInfo(TableDesc valueSerializeInfo)

Methods inherited from class java.lang.Object

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

getKeyCols

public ArrayList<ExprNodeDesc> getKeyCols()

setKeyCols

public void setKeyCols(ArrayList<ExprNodeDesc> keyCols)

getNumDistributionKeys

public int getNumDistributionKeys()

setNumDistributionKeys

public void setNumDistributionKeys(int numKeys)

getValueCols

public ArrayList<ExprNodeDesc> getValueCols()

setValueCols

public void setValueCols(ArrayList<ExprNodeDesc> valueCols)

getPartitionCols

public ArrayList<ExprNodeDesc> getPartitionCols()

setPartitionCols

public void setPartitionCols(ArrayList<ExprNodeDesc> partitionCols)

getTag

public int getTag()

setTag

public void setTag(int tag)

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)