public abstract class BaseWork extends AbstractOperatorDesc
Modifier and Type | Class and Description |
---|---|
static class |
BaseWork.BaseExplainVectorization |
Modifier and Type | Field and Description |
---|---|
protected Set<VectorizedSupport.Support> |
inputFormatSupportSet |
protected boolean |
llapMode |
protected static org.slf4j.Logger |
LOG |
protected List<String> |
supportRemovedReasons |
protected Set<VectorizedSupport.Support> |
supportSetInUse |
protected boolean |
uberMode |
protected boolean |
useVectorizedInputFileFormat |
protected boolean |
vectorizationEnabled |
protected boolean |
vectorizationExamined |
protected VectorizedRowBatchCtx |
vectorizedRowBatchCtx |
protected int |
vectorizedTestingReducerBatchSize |
protected long |
vectorizedVertexNum |
colExprMap, memAvailable, memNeeded, opProps, opTraits, runtimeStatsTmpDir, statistics, vectorDesc, vectorMode
clone, fillSignature, getColumnExprMap, getColumnExprMapForExplain, getMaxMemoryAvailable, getMemoryNeeded, getOpProps, getRuntimeStatsTmpDir, getStatistics, getTraits, getUserLevelStatistics, getVectorDesc, getVectorMode, isSame, setColumnExprMap, setMaxMemoryAvailable, setMemoryNeeded, setOpProps, setRuntimeStatsTmpDir, setStatistics, setTraits, setVectorDesc, setVectorMode
protected static final org.slf4j.Logger LOG
protected boolean vectorizationExamined
protected boolean vectorizationEnabled
protected VectorizedRowBatchCtx vectorizedRowBatchCtx
protected boolean useVectorizedInputFileFormat
protected Set<VectorizedSupport.Support> inputFormatSupportSet
protected Set<VectorizedSupport.Support> supportSetInUse
protected long vectorizedVertexNum
protected int vectorizedTestingReducerBatchSize
protected boolean llapMode
protected boolean uberMode
public BaseWork()
public BaseWork(String name)
public void setGatheringStats(boolean gatherStats)
public boolean isGatheringStats()
public String getName()
public void setName(String name)
public List<HashTableDummyOperator> getDummyOps()
public void setDummyOps(List<HashTableDummyOperator> dummyOps)
public void addDummyOp(HashTableDummyOperator dummyOp)
public abstract Set<Operator<? extends OperatorDesc>> getAllRootOperators()
public abstract Operator<? extends OperatorDesc> getAnyRootOperator()
public Set<Operator<? extends OperatorDesc>> getAllLeafOperators()
public void setVectorizedVertexNum(long vectorizedVertexNum)
public long getVectorizedVertexNum()
public void setVectorizedTestingReducerBatchSize(int vectorizedTestingReducerBatchSize)
public int getVectorizedTestingReducerBatchSize()
public void setVectorizationExamined(boolean vectorizationExamined)
public boolean getVectorizationExamined()
public void setVectorizationEnabled(boolean vectorizationEnabled)
public boolean getVectorizationEnabled()
public VectorizedRowBatchCtx getVectorizedRowBatchCtx()
public void setVectorizedRowBatchCtx(VectorizedRowBatchCtx vectorizedRowBatchCtx)
public void setNotVectorizedReason(VectorizerReason notVectorizedReason)
public VectorizerReason getNotVectorizedReason()
public void setUsesVectorUDFAdaptor(boolean usesVectorUDFAdaptor)
public boolean getUsesVectorUDFAdaptor()
public void setAllNative(boolean allNative)
public boolean getAllNative()
public void setIsTestForcedVectorizationEnable(boolean isTestForcedVectorizationEnable)
public boolean getIsTestForcedVectorizationEnable()
public void setIsTestVectorizationSuppressExplainExecutionMode(boolean isTestVectorizationSuppressExplainExecutionMode)
public boolean getIsTestVectorizationSuppressExplainExecutionMode()
public MapredLocalWork getMapRedLocalWork()
public void setMapRedLocalWork(MapredLocalWork mapLocalWork)
mapLocalWork
- the mapredLocalWork to setpublic void setUberMode(boolean uberMode)
public boolean getUberMode()
public void setLlapMode(boolean llapMode)
public boolean getLlapMode()
public int getReservedMemoryMB()
public void setReservedMemoryMB(int memoryMB)
public abstract void configureJobConf(org.apache.hadoop.mapred.JobConf job)
public void setTag(int tag)
public int getTag()
public Map<String,RuntimeValuesInfo> getInputSourceToRuntimeValuesInfo()
public void setInputSourceToRuntimeValuesInfo(String workName, RuntimeValuesInfo runtimeValuesInfo)
Copyright © 2022 The Apache Software Foundation. All rights reserved.