public class ReduceWork extends BaseWork
Modifier and Type | Class and Description |
---|---|
class |
ReduceWork.ReduceExplainVectorization |
BaseWork.BaseExplainVectorization
inputFormatSupportSet, llapMode, LOG, supportRemovedReasons, supportSetInUse, uberMode, useVectorizedInputFileFormat, vectorizationEnabled, vectorizationExamined, vectorizedRowBatchCtx, vectorizedTestingReducerBatchSize, vectorizedVertexNum
colExprMap, memAvailable, memNeeded, opProps, opTraits, runtimeStatsTmpDir, statistics, vectorDesc, vectorMode
Constructor and Description |
---|
ReduceWork() |
ReduceWork(String name) |
addDummyOp, addSortCols, getAllLeafOperators, getAllNative, getAllOperators, getDummyOps, getInputSourceToRuntimeValuesInfo, getIsTestForcedVectorizationEnable, getIsTestVectorizationSuppressExplainExecutionMode, getLlapMode, getMapRedLocalWork, getName, getNotVectorizedReason, getReservedMemoryMB, getSortCols, getTag, getUberMode, getUsesVectorUDFAdaptor, getVectorizationEnabled, getVectorizationExamined, getVectorizedRowBatchCtx, getVectorizedTestingReducerBatchSize, getVectorizedVertexNum, isGatheringStats, setAllNative, setDummyOps, setGatheringStats, setInputSourceToRuntimeValuesInfo, setIsTestForcedVectorizationEnable, setIsTestVectorizationSuppressExplainExecutionMode, setLlapMode, setMapRedLocalWork, setName, setNotVectorizedReason, setReservedMemoryMB, setTag, setUberMode, setUsesVectorUDFAdaptor, setVectorizationEnabled, setVectorizationExamined, setVectorizedRowBatchCtx, setVectorizedTestingReducerBatchSize, setVectorizedVertexNum
clone, fillSignature, getColumnExprMap, getColumnExprMapForExplain, getMaxMemoryAvailable, getMemoryNeeded, getOpProps, getRuntimeStatsTmpDir, getStatistics, getTraits, getUserLevelStatistics, getVectorDesc, getVectorMode, isSame, setColumnExprMap, setMaxMemoryAvailable, setMemoryNeeded, setOpProps, setRuntimeStatsTmpDir, setStatistics, setTraits, setVectorDesc, setVectorMode
public ReduceWork()
public ReduceWork(String name)
public void setKeyDesc(TableDesc keyDesc)
keyDesc
- public TableDesc getKeyDesc()
public String getExecutionMode()
public Operator<?> getReducer()
public void setReducer(Operator<?> reducer)
public boolean getNeedsTagging()
public void setNeedsTagging(boolean needsTagging)
public void replaceRoots(Map<Operator<?>,Operator<?>> replacementMap)
replaceRoots
in class BaseWork
public Set<Operator<?>> getAllRootOperators()
getAllRootOperators
in class BaseWork
public Operator<? extends OperatorDesc> getAnyRootOperator()
getAnyRootOperator
in class BaseWork
public Integer getNumReduceTasks()
public void setNumReduceTasks(Integer numReduceTasks)
public void configureJobConf(org.apache.hadoop.mapred.JobConf job)
configureJobConf
in class BaseWork
public void setAutoReduceParallelism(boolean isAutoReduceParallelism)
public boolean isAutoReduceParallelism()
public boolean isSlowStart()
public void setSlowStart(boolean isSlowStart)
public void setUniformDistribution(boolean isUniformDistribution)
public boolean isUniformDistribution()
public void setMinReduceTasks(int minReduceTasks)
public int getMinReduceTasks()
public int getMaxReduceTasks()
public void setMaxReduceTasks(int maxReduceTasks)
public void setReduceVectorizationEnabled(boolean reduceVectorizationEnabled)
public boolean getReduceVectorizationEnabled()
public void setVectorReduceEngine(String vectorReduceEngine)
public String getVectorReduceEngine()
public void setVectorReduceColumnSortOrder(String vectorReduceColumnSortOrder)
public String getVectorReduceColumnSortOrder()
public void setVectorReduceColumnNullOrder(String vectorReduceColumnNullOrder)
public String getVectorReduceColumnNullOrder()
public ReduceWork.ReduceExplainVectorization getReduceExplainVectorization()
public void setEdgePropRef(TezEdgeProperty edgeProp)
public TezEdgeProperty getEdgePropRef()
Copyright © 2022 The Apache Software Foundation. All rights reserved.