public abstract class BaseWork extends AbstractOperatorDesc
Modifier and Type | Field and Description |
---|---|
protected boolean |
llapMode |
protected static org.slf4j.Logger |
LOG |
protected boolean |
uberMode |
protected boolean |
useVectorizedInputFileFormat |
protected VectorizedRowBatchCtx |
vectorizedRowBatchCtx |
memNeeded, opProps, opTraits, statistics, vectorMode
clone, getMemoryNeeded, getOpProps, getStatistics, getTraits, getUserLevelStatistics, getVectorMode, setMemoryNeeded, setOpProps, setStatistics, setTraits, setVectorMode
protected static final org.slf4j.Logger LOG
protected VectorizedRowBatchCtx vectorizedRowBatchCtx
protected boolean useVectorizedInputFileFormat
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 VectorizedRowBatchCtx getVectorizedRowBatchCtx()
public void setVectorizedRowBatchCtx(VectorizedRowBatchCtx vectorizedRowBatchCtx)
public void setUseVectorizedInputFileFormat(boolean useVectorizedInputFileFormat)
public boolean getUseVectorizedInputFileFormat()
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()
Copyright © 2016 The Apache Software Foundation. All rights reserved.