public class FileSinkDesc extends AbstractOperatorDesc
Modifier and Type | Class and Description |
---|---|
static class |
FileSinkDesc.DPSortState |
memNeeded, opProps, opTraits, statistics, 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) |
getMemoryNeeded, getOpProps, getStatistics, getTraits, getUserLevelStatistics, getVectorMode, setMemoryNeeded, setOpProps, setStatistics, setTraits, 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)
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 isUsingThriftJDBCBinarySerDe()
public void setIsUsingThriftJDBCBinarySerDe(boolean isUsingThriftJDBCBinarySerDe)
public org.apache.hadoop.fs.Path getDirName()
public void setDirName(org.apache.hadoop.fs.Path dirName)
public org.apache.hadoop.fs.Path getFinalDirName()
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 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()
public String getStatsAggPrefix()
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 void setParentDir(org.apache.hadoop.fs.Path parentDir)
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 void setDpSortState(FileSinkDesc.DPSortState dpSortState)
public void setWriteType(AcidUtils.Operation type)
public AcidUtils.Operation getWriteType()
public void setTransactionId(long id)
public long getTransactionId()
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 getStatsTmpDir()
public void setStatsTmpDir(String statsCollectionTempDir)
public int getIndexInTezUnion()
public void setIndexInTezUnion(int indexInTezUnion)
Copyright © 2016 The Apache Software Foundation. All rights reserved.