public class FileSinkDesc extends AbstractOperatorDesc implements IStatsGatherDesc
Modifier and Type | Class and Description |
---|---|
static class |
FileSinkDesc.DPSortState |
class |
FileSinkDesc.FileSinkOperatorExplainVectorization |
colExprMap, memAvailable, memNeeded, opProps, opTraits, runtimeStatsTmpDir, statistics, vectorDesc, vectorMode
Constructor and Description |
---|
FileSinkDesc() |
FileSinkDesc(org.apache.hadoop.fs.Path dirName,
TableDesc tableInfo,
boolean compressed) |
FileSinkDesc(org.apache.hadoop.fs.Path dirName,
TableDesc tableInfo,
boolean compressed,
int destTableId,
boolean multiFileSpray,
boolean canBeMerged,
int numFiles,
int totalFiles,
ArrayList<ExprNodeDesc> partitionCols,
DynamicPartitionCtx dpCtx,
org.apache.hadoop.fs.Path destPath,
Long mmWriteId,
boolean isMmCtas,
boolean isInsertOverwrite) |
fillSignature, getColumnExprMap, getColumnExprMapForExplain, getMaxMemoryAvailable, getMemoryNeeded, getOpProps, getRuntimeStatsTmpDir, getStatistics, getTraits, getUserLevelStatistics, getVectorDesc, getVectorMode, setColumnExprMap, setMaxMemoryAvailable, setMemoryNeeded, setOpProps, setRuntimeStatsTmpDir, setStatistics, setTraits, setVectorDesc, setVectorMode
public FileSinkDesc()
public FileSinkDesc(org.apache.hadoop.fs.Path dirName, TableDesc tableInfo, boolean compressed, int destTableId, boolean multiFileSpray, boolean canBeMerged, int numFiles, int totalFiles, ArrayList<ExprNodeDesc> partitionCols, DynamicPartitionCtx dpCtx, org.apache.hadoop.fs.Path destPath, Long mmWriteId, boolean isMmCtas, boolean isInsertOverwrite)
destPath
- - the final destination for datapublic FileSinkDesc(org.apache.hadoop.fs.Path dirName, TableDesc tableInfo, boolean compressed)
public Object clone() throws CloneNotSupportedException
clone
in interface OperatorDesc
clone
in class AbstractOperatorDesc
CloneNotSupportedException
public boolean isHiveServerQuery()
public void setHiveServerQuery(boolean isHiveServerQuery)
public boolean isUsingBatchingSerDe()
public void setIsUsingBatchingSerDe(boolean isUsingBatchingSerDe)
public org.apache.hadoop.fs.Path getDirName()
public String getDirNameString()
public void setDirName(org.apache.hadoop.fs.Path dirName)
public org.apache.hadoop.fs.Path getFinalDirName()
public org.apache.hadoop.fs.Path getMergeInputDirName()
public TableDesc getTableInfo()
public void setTableInfo(TableDesc tableInfo)
public boolean getCompressed()
public void setCompressed(boolean compressed)
public int getDestTableId()
public void setDestTableId(int destTableId)
public String getCompressCodec()
public void setCompressCodec(String intermediateCompressorCodec)
public String getCompressType()
public void setCompressType(String intermediateCompressType)
public boolean isMultiFileSpray()
public void setMultiFileSpray(boolean multiFileSpray)
multiFileSpray
- the multiFileSpray to setpublic boolean isTemporary()
public void setTemporary(boolean temporary)
public boolean isMmTable()
public boolean isFullAcidTable()
public boolean isMaterialization()
public void setMaterialization(boolean materialization)
public boolean canBeMerged()
public void setCanBeMerged(boolean canBeMerged)
public int getTotalFiles()
public void setTotalFiles(int totalFiles)
totalFiles
- the totalFiles to setpublic ArrayList<ExprNodeDesc> getPartitionCols()
public void setPartitionCols(ArrayList<ExprNodeDesc> partitionCols)
partitionCols
- the partitionCols to setpublic int getNumFiles()
public void setNumFiles(int numFiles)
numFiles
- the numFiles to setpublic void setDynPartCtx(DynamicPartitionCtx dpc)
public DynamicPartitionCtx getDynPartCtx()
public void setStaticSpec(String staticSpec)
public String getStaticSpec()
public void setGatherStats(boolean gatherStats)
public boolean isGatherStats()
isGatherStats
in interface IStatsGatherDesc
public String getStatsAggPrefix()
getStatsAggPrefix
in interface IStatsGatherDesc
public void setStatsAggPrefix(String k)
k
- input directory name.public boolean isLinkedFileSink()
public void setLinkedFileSink(boolean linkedFileSink)
public org.apache.hadoop.fs.Path getParentDir()
public boolean isStatsReliable()
public void setStatsReliable(boolean statsReliable)
public ListBucketingCtx getLbCtx()
public void setLbCtx(ListBucketingCtx lbCtx)
lbCtx
- the lbCtx to setpublic List<FileSinkDesc> getLinkedFileSinkDesc()
public void setLinkedFileSinkDesc(List<FileSinkDesc> linkedFileSinkDesc)
public boolean isRemovedReduceSinkBucketSort()
public void setRemovedReduceSinkBucketSort(boolean removedReduceSinkBucketSort)
public FileSinkDesc.DPSortState getDpSortState()
public String getDpSortStateString()
public void setDpSortState(FileSinkDesc.DPSortState dpSortState)
public void setWriteType(AcidUtils.Operation type)
public AcidUtils.Operation getWriteType()
public String getWriteTypeString()
public void setTableWriteId(long id)
public long getTableWriteId()
public void setStatementId(int id)
public int getStatementId()
public org.apache.hadoop.fs.Path getDestPath()
public Table getTable()
public void setTable(Table table)
public String getTmpStatsDir()
getTmpStatsDir
in interface IStatsGatherDesc
public void setStatsTmpDir(String statsCollectionTempDir)
public void setMmWriteId(Long mmWriteId)
public void setIsMerge(boolean b)
public boolean isMerge()
public boolean isMmCtas()
public FileSinkDesc.FileSinkOperatorExplainVectorization getFileSinkVectorization()
public void setInsertOverwrite(boolean isInsertOverwrite)
public boolean getInsertOverwrite()
public boolean isSame(OperatorDesc other)
AbstractOperatorDesc
Object.equals(Object)
. Intended to be
overridden by sub classes.isSame
in interface OperatorDesc
isSame
in class AbstractOperatorDesc
Copyright © 2022 The Apache Software Foundation. All rights reserved.