public class ReduceSinkDesc extends AbstractOperatorDesc
Constructor and Description |
---|
ReduceSinkDesc() |
ReduceSinkDesc(java.util.ArrayList<ExprNodeDesc> keyCols,
int numDistributionKeys,
java.util.ArrayList<ExprNodeDesc> valueCols,
java.util.ArrayList<java.lang.String> outputKeyColumnNames,
java.util.List<java.util.List<java.lang.Integer>> distinctColumnIndices,
java.util.ArrayList<java.lang.String> outputValueColumnNames,
int tag,
java.util.ArrayList<ExprNodeDesc> partitionCols,
int numReducers,
TableDesc keySerializeInfo,
TableDesc valueSerializeInfo) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
clone() |
java.util.List<java.util.List<java.lang.Integer>> |
getDistinctColumnIndices() |
java.util.ArrayList<ExprNodeDesc> |
getKeyCols() |
TableDesc |
getKeySerializeInfo() |
int |
getNumDistributionKeys() |
int |
getNumReducers()
Returns the number of reducers for the map-reduce job.
|
java.lang.String |
getOrder()
Returns the sort order of the key columns.
|
java.util.ArrayList<java.lang.String> |
getOutputKeyColumnNames() |
java.util.ArrayList<java.lang.String> |
getOutputValueColumnNames() |
java.util.ArrayList<ExprNodeDesc> |
getPartitionCols() |
int |
getTag() |
int |
getTopN() |
java.lang.Integer |
getTopNExplain() |
float |
getTopNMemoryUsage() |
java.lang.Float |
getTopNMemoryUsageExplain() |
java.util.ArrayList<ExprNodeDesc> |
getValueCols() |
TableDesc |
getValueSerializeInfo() |
boolean |
isMapGroupBy() |
void |
setDistinctColumnIndices(java.util.List<java.util.List<java.lang.Integer>> distinctColumnIndices) |
void |
setKeyCols(java.util.ArrayList<ExprNodeDesc> keyCols) |
void |
setKeySerializeInfo(TableDesc keySerializeInfo) |
void |
setMapGroupBy(boolean mapGroupBy) |
void |
setNumDistributionKeys(int numKeys) |
void |
setNumReducers(int numReducers) |
void |
setOrder(java.lang.String orderStr) |
void |
setOutputKeyColumnNames(java.util.ArrayList<java.lang.String> outputKeyColumnNames) |
void |
setOutputValueColumnNames(java.util.ArrayList<java.lang.String> outputValueColumnNames) |
void |
setPartitionCols(java.util.ArrayList<ExprNodeDesc> partitionCols) |
void |
setTag(int tag) |
void |
setTopN(int topN) |
void |
setTopNMemoryUsage(float topNMemoryUsage) |
void |
setValueCols(java.util.ArrayList<ExprNodeDesc> valueCols) |
void |
setValueSerializeInfo(TableDesc valueSerializeInfo) |
public ReduceSinkDesc()
public ReduceSinkDesc(java.util.ArrayList<ExprNodeDesc> keyCols, int numDistributionKeys, java.util.ArrayList<ExprNodeDesc> valueCols, java.util.ArrayList<java.lang.String> outputKeyColumnNames, java.util.List<java.util.List<java.lang.Integer>> distinctColumnIndices, java.util.ArrayList<java.lang.String> outputValueColumnNames, int tag, java.util.ArrayList<ExprNodeDesc> partitionCols, int numReducers, TableDesc keySerializeInfo, TableDesc valueSerializeInfo)
public java.lang.Object clone()
clone
in interface OperatorDesc
clone
in class AbstractOperatorDesc
public java.util.ArrayList<java.lang.String> getOutputKeyColumnNames()
public void setOutputKeyColumnNames(java.util.ArrayList<java.lang.String> outputKeyColumnNames)
public java.util.ArrayList<java.lang.String> getOutputValueColumnNames()
public void setOutputValueColumnNames(java.util.ArrayList<java.lang.String> outputValueColumnNames)
public java.util.ArrayList<ExprNodeDesc> getKeyCols()
public void setKeyCols(java.util.ArrayList<ExprNodeDesc> keyCols)
public int getNumDistributionKeys()
public void setNumDistributionKeys(int numKeys)
public java.util.ArrayList<ExprNodeDesc> getValueCols()
public void setValueCols(java.util.ArrayList<ExprNodeDesc> valueCols)
public java.util.ArrayList<ExprNodeDesc> getPartitionCols()
public void setPartitionCols(java.util.ArrayList<ExprNodeDesc> partitionCols)
public int getTag()
public void setTag(int tag)
public int getTopN()
public void setTopN(int topN)
public java.lang.Integer getTopNExplain()
public float getTopNMemoryUsage()
public void setTopNMemoryUsage(float topNMemoryUsage)
public java.lang.Float getTopNMemoryUsageExplain()
public boolean isMapGroupBy()
public void setMapGroupBy(boolean mapGroupBy)
public int getNumReducers()
public void setNumReducers(int numReducers)
public TableDesc getKeySerializeInfo()
public void setKeySerializeInfo(TableDesc keySerializeInfo)
public TableDesc getValueSerializeInfo()
public void setValueSerializeInfo(TableDesc valueSerializeInfo)
public java.lang.String getOrder()
public void setOrder(java.lang.String orderStr)
public java.util.List<java.util.List<java.lang.Integer>> getDistinctColumnIndices()
public void setDistinctColumnIndices(java.util.List<java.util.List<java.lang.Integer>> distinctColumnIndices)
Copyright © 2012 The Apache Software Foundation