public class ReduceSinkDesc extends AbstractOperatorDesc
Modifier and Type | Class and Description |
---|---|
static class |
ReduceSinkDesc.ReducerTraits |
class |
ReduceSinkDesc.ReduceSinkOperatorExplainVectorization |
colExprMap, memAvailable, memNeeded, opProps, opTraits, runtimeStatsTmpDir, statistics, vectorDesc, vectorMode
Constructor and Description |
---|
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,
AcidUtils.Operation writeType) |
fillSignature, getColumnExprMap, getColumnExprMapForExplain, getMaxMemoryAvailable, getMemoryNeeded, getOpProps, getRuntimeStatsTmpDir, getStatistics, getTraits, getUserLevelStatistics, getVectorDesc, getVectorMode, setColumnExprMap, setMaxMemoryAvailable, setMemoryNeeded, setOpProps, setRuntimeStatsTmpDir, setStatistics, setTraits, setVectorDesc, setVectorMode
public 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, AcidUtils.Operation writeType)
public Object clone()
clone
in interface OperatorDesc
clone
in class AbstractOperatorDesc
public void setOutputValueColumnNames(ArrayList<String> outputValueColumnNames)
public String getKeyColString()
public ArrayList<ExprNodeDesc> getKeyCols()
public void setKeyCols(ArrayList<ExprNodeDesc> keyCols)
public int getNumDistributionKeys()
public void setNumDistributionKeys(int numKeys)
public String getValueColsString()
public ArrayList<ExprNodeDesc> getValueCols()
public void setValueCols(ArrayList<ExprNodeDesc> valueCols)
public String getParitionColsString()
public String getUserLevelExplainParitionColsString()
public ArrayList<ExprNodeDesc> getPartitionCols()
public void setPartitionCols(ArrayList<ExprNodeDesc> partitionCols)
public boolean isPartitioning()
public int getTag()
public void setTag(int tag)
public int getTopN()
public void setTopN(int topN)
public Integer getTopNExplain()
public float getTopNMemoryUsage()
public void setTopNMemoryUsage(float topNMemoryUsage)
public Float getTopNMemoryUsageExplain()
public boolean isMapGroupBy()
public void setMapGroupBy(boolean mapGroupBy)
public boolean isPTFReduceSink()
public void setPTFReduceSink(boolean isPTFReduceSink)
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 String getOrder()
public void setOrder(String orderStr)
public boolean isOrdering()
public String getNullOrder()
public void setNullOrder(String nullOrderStr)
public void setDistinctColumnIndices(List<List<Integer>> distinctColumnIndices)
public String getOutputName()
public void setOutputName(String outputName)
public int getNumBuckets()
public void setNumBuckets(int numBuckets)
public List<ExprNodeDesc> getBucketCols()
public void setBucketCols(List<ExprNodeDesc> bucketCols)
public void setSkipTag(boolean value)
public boolean getSkipTag()
public void setForwarding(boolean forwarding)
public boolean isForwarding()
public final boolean isAutoParallel()
public final boolean isSlowStart()
public final boolean isQuickStart()
public final EnumSet<ReduceSinkDesc.ReducerTraits> getReducerTraits()
public final void setReducerTraits(EnumSet<ReduceSinkDesc.ReducerTraits> traits)
public boolean isDeduplicated()
public void setDeduplicated(boolean isDeduplicated)
public boolean hasOrderBy()
public void setHasOrderBy(boolean hasOrderBy)
public ReduceSinkDesc.ReduceSinkOperatorExplainVectorization getReduceSinkVectorization()
public boolean isSame(OperatorDesc other)
AbstractOperatorDesc
Object.equals(Object)
. Intended to be
overridden by sub classes.isSame
in interface OperatorDesc
isSame
in class AbstractOperatorDesc
public AcidUtils.Operation getWriteType()
Copyright © 2022 The Apache Software Foundation. All rights reserved.