public class FetchWork
extends java.lang.Object
implements java.io.Serializable
Constructor and Description |
---|
FetchWork() |
FetchWork(java.util.List<java.lang.String> partDir,
java.util.List<PartitionDesc> partDesc,
TableDesc tblDesc) |
FetchWork(java.util.List<java.lang.String> partDir,
java.util.List<PartitionDesc> partDesc,
TableDesc tblDesc,
int limit) |
FetchWork(java.lang.String tblDir,
TableDesc tblDesc) |
FetchWork(java.lang.String tblDir,
TableDesc tblDesc,
int limit) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<java.lang.String> |
convertPathToStringArray(java.util.List<Path> paths) |
static java.util.List<Path> |
convertStringToPathArray(java.util.List<java.lang.String> paths) |
int |
getLeastNumRows() |
int |
getLimit() |
java.util.ArrayList<PartitionDesc> |
getPartDesc() |
java.util.ArrayList<PartitionDesc> |
getPartDescOrderedByPartDir()
Get Partition descriptors in sorted (ascending) order of partition directory
|
java.util.List<PartitionDesc> |
getPartDescs(java.util.List<Path> paths) |
java.util.ArrayList<java.lang.String> |
getPartDir() |
java.util.List<Path> |
getPartDirPath() |
java.lang.String |
getSerializationNullFormat() |
ListSinkOperator |
getSink() |
Operator<?> |
getSource() |
SplitSample |
getSplitSample() |
TableDesc |
getTblDesc() |
java.lang.String |
getTblDir() |
Path |
getTblDirPath() |
void |
initializeForFetch() |
boolean |
isNotPartitioned() |
boolean |
isPartitioned() |
void |
setLeastNumRows(int leastNumRows) |
void |
setLimit(int limit) |
void |
setPartDesc(java.util.ArrayList<PartitionDesc> partDesc) |
void |
setPartDir(java.util.ArrayList<java.lang.String> partDir) |
void |
setSerializationNullFormat(java.lang.String format) |
void |
setSink(ListSinkOperator sink) |
void |
setSource(Operator<?> source) |
void |
setSplitSample(SplitSample splitSample) |
void |
setTblDesc(TableDesc tblDesc) |
void |
setTblDir(java.lang.String tblDir) |
java.lang.String |
toString() |
public FetchWork()
public FetchWork(java.lang.String tblDir, TableDesc tblDesc)
public FetchWork(java.lang.String tblDir, TableDesc tblDesc, int limit)
public FetchWork(java.util.List<java.lang.String> partDir, java.util.List<PartitionDesc> partDesc, TableDesc tblDesc)
public FetchWork(java.util.List<java.lang.String> partDir, java.util.List<PartitionDesc> partDesc, TableDesc tblDesc, int limit)
public void initializeForFetch()
public java.lang.String getSerializationNullFormat()
public void setSerializationNullFormat(java.lang.String format)
public boolean isNotPartitioned()
public boolean isPartitioned()
public java.lang.String getTblDir()
public Path getTblDirPath()
public void setTblDir(java.lang.String tblDir)
tblDir
- the tblDir to setpublic TableDesc getTblDesc()
public void setTblDesc(TableDesc tblDesc)
tblDesc
- the tblDesc to setpublic java.util.ArrayList<java.lang.String> getPartDir()
public java.util.List<Path> getPartDirPath()
public static java.util.List<java.lang.String> convertPathToStringArray(java.util.List<Path> paths)
public static java.util.List<Path> convertStringToPathArray(java.util.List<java.lang.String> paths)
public void setPartDir(java.util.ArrayList<java.lang.String> partDir)
partDir
- the partDir to setpublic java.util.ArrayList<PartitionDesc> getPartDesc()
public java.util.ArrayList<PartitionDesc> getPartDescOrderedByPartDir()
public java.util.List<PartitionDesc> getPartDescs(java.util.List<Path> paths)
public void setPartDesc(java.util.ArrayList<PartitionDesc> partDesc)
partDesc
- the partDesc to setpublic int getLimit()
public void setLimit(int limit)
limit
- the limit to setpublic int getLeastNumRows()
public void setLeastNumRows(int leastNumRows)
public Operator<?> getSource()
public void setSource(Operator<?> source)
public ListSinkOperator getSink()
public void setSink(ListSinkOperator sink)
public void setSplitSample(SplitSample splitSample)
public SplitSample getSplitSample()
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2012 The Apache Software Foundation