public class FileSinkDesc extends AbstractOperatorDesc
Constructor and Description |
---|
FileSinkDesc() |
FileSinkDesc(java.lang.String dirName,
TableDesc tableInfo,
boolean compressed) |
FileSinkDesc(java.lang.String dirName,
TableDesc tableInfo,
boolean compressed,
int destTableId,
boolean multiFileSpray,
boolean canBeMerged,
int numFiles,
int totalFiles,
java.util.ArrayList<ExprNodeDesc> partitionCols,
DynamicPartitionCtx dpCtx) |
Modifier and Type | Method and Description |
---|---|
boolean |
canBeMerged() |
java.lang.Object |
clone() |
java.lang.String |
getCompressCodec() |
boolean |
getCompressed() |
java.lang.String |
getCompressType() |
int |
getDestTableId() |
java.lang.String |
getDirName() |
DynamicPartitionCtx |
getDynPartCtx() |
java.lang.String |
getFinalDirName() |
ListBucketingCtx |
getLbCtx() |
java.util.List<FileSinkDesc> |
getLinkedFileSinkDesc() |
int |
getMaxStatsKeyPrefixLength() |
int |
getNumFiles() |
java.lang.String |
getParentDir() |
java.util.ArrayList<ExprNodeDesc> |
getPartitionCols() |
java.lang.String |
getStaticSpec() |
java.lang.String |
getStatsAggPrefix()
Construct the key prefix used as (intermediate) statistics publishing
and aggregation.
|
TableDesc |
getTableInfo() |
int |
getTotalFiles() |
boolean |
isGatherStats() |
boolean |
isLinkedFileSink() |
boolean |
isMultiFileSpray() |
boolean |
isRemovedReduceSinkBucketSort() |
boolean |
isStatsCollectRawDataSize() |
boolean |
isStatsReliable() |
void |
setCanBeMerged(boolean canBeMerged) |
void |
setCompressCodec(java.lang.String intermediateCompressorCodec) |
void |
setCompressed(boolean compressed) |
void |
setCompressType(java.lang.String intermediateCompressType) |
void |
setDestTableId(int destTableId) |
void |
setDirName(java.lang.String dirName) |
void |
setDynPartCtx(DynamicPartitionCtx dpc) |
void |
setGatherStats(boolean gatherStats) |
void |
setLbCtx(ListBucketingCtx lbCtx) |
void |
setLinkedFileSink(boolean linkedFileSink) |
void |
setLinkedFileSinkDesc(java.util.List<FileSinkDesc> linkedFileSinkDesc) |
void |
setMaxStatsKeyPrefixLength(int maxStatsKeyPrefixLength) |
void |
setMultiFileSpray(boolean multiFileSpray) |
void |
setNumFiles(int numFiles) |
void |
setParentDir(java.lang.String parentDir) |
void |
setPartitionCols(java.util.ArrayList<ExprNodeDesc> partitionCols) |
void |
setRemovedReduceSinkBucketSort(boolean removedReduceSinkBucketSort) |
void |
setStaticSpec(java.lang.String staticSpec) |
void |
setStatsAggPrefix(java.lang.String k)
Set the stats aggregation key.
|
void |
setStatsCollectRawDataSize(boolean statsCollectRawDataSize) |
void |
setStatsReliable(boolean statsReliable) |
void |
setTableInfo(TableDesc tableInfo) |
void |
setTotalFiles(int totalFiles) |
public FileSinkDesc()
public FileSinkDesc(java.lang.String dirName, TableDesc tableInfo, boolean compressed, int destTableId, boolean multiFileSpray, boolean canBeMerged, int numFiles, int totalFiles, java.util.ArrayList<ExprNodeDesc> partitionCols, DynamicPartitionCtx dpCtx)
public FileSinkDesc(java.lang.String dirName, TableDesc tableInfo, boolean compressed)
public java.lang.Object clone() throws java.lang.CloneNotSupportedException
clone
in interface OperatorDesc
clone
in class AbstractOperatorDesc
java.lang.CloneNotSupportedException
public java.lang.String getDirName()
public void setDirName(java.lang.String dirName)
public java.lang.String 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 java.lang.String getCompressCodec()
public void setCompressCodec(java.lang.String intermediateCompressorCodec)
public java.lang.String getCompressType()
public void setCompressType(java.lang.String intermediateCompressType)
public boolean isMultiFileSpray()
public void setMultiFileSpray(boolean multiFileSpray)
multiFileSpray
- the multiFileSpray to setpublic boolean canBeMerged()
public void setCanBeMerged(boolean canBeMerged)
public int getTotalFiles()
public void setTotalFiles(int totalFiles)
totalFiles
- the totalFiles to setpublic java.util.ArrayList<ExprNodeDesc> getPartitionCols()
public void setPartitionCols(java.util.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(java.lang.String staticSpec)
public java.lang.String getStaticSpec()
public void setGatherStats(boolean gatherStats)
public boolean isGatherStats()
public java.lang.String getStatsAggPrefix()
public void setStatsAggPrefix(java.lang.String k)
k
- input directory name.public boolean isLinkedFileSink()
public void setLinkedFileSink(boolean linkedFileSink)
public java.lang.String getParentDir()
public void setParentDir(java.lang.String parentDir)
public boolean isStatsReliable()
public void setStatsReliable(boolean statsReliable)
public ListBucketingCtx getLbCtx()
public void setLbCtx(ListBucketingCtx lbCtx)
lbCtx
- the lbCtx to setpublic java.util.List<FileSinkDesc> getLinkedFileSinkDesc()
public void setLinkedFileSinkDesc(java.util.List<FileSinkDesc> linkedFileSinkDesc)
public int getMaxStatsKeyPrefixLength()
public void setMaxStatsKeyPrefixLength(int maxStatsKeyPrefixLength)
public boolean isStatsCollectRawDataSize()
public void setStatsCollectRawDataSize(boolean statsCollectRawDataSize)
public boolean isRemovedReduceSinkBucketSort()
public void setRemovedReduceSinkBucketSort(boolean removedReduceSinkBucketSort)
Copyright © 2012 The Apache Software Foundation