public class FetchWork extends Object implements Serializable
Modifier and Type | Class and Description |
---|---|
class |
FetchWork.FetchExplainVectorization |
Constructor and Description |
---|
FetchWork() |
FetchWork(List<List<Object>> rowsComputedFromStats,
StructObjectInspector statRowOI) |
FetchWork(List<org.apache.hadoop.fs.Path> partDir,
List<PartitionDesc> partDesc,
TableDesc tblDesc) |
FetchWork(List<org.apache.hadoop.fs.Path> partDir,
List<PartitionDesc> partDesc,
TableDesc tblDesc,
int limit) |
FetchWork(org.apache.hadoop.fs.Path tblDir,
TableDesc tblDesc) |
FetchWork(org.apache.hadoop.fs.Path tblDir,
TableDesc tblDesc,
int limit) |
public FetchWork()
public FetchWork(List<List<Object>> rowsComputedFromStats, StructObjectInspector statRowOI)
public FetchWork(org.apache.hadoop.fs.Path tblDir, TableDesc tblDesc)
public FetchWork(org.apache.hadoop.fs.Path tblDir, TableDesc tblDesc, int limit)
public FetchWork(List<org.apache.hadoop.fs.Path> partDir, List<PartitionDesc> partDesc, TableDesc tblDesc)
public FetchWork(List<org.apache.hadoop.fs.Path> partDir, List<PartitionDesc> partDesc, TableDesc tblDesc, int limit)
public boolean isHiveServerQuery()
public void setHiveServerQuery(boolean isHiveServerQuery)
public boolean isUsingThriftJDBCBinarySerDe()
public void setIsUsingThriftJDBCBinarySerDe(boolean isUsingThriftJDBCBinarySerDe)
public StructObjectInspector getStatRowOI()
public void initializeForFetch(CompilationOpContext ctx)
public String getSerializationNullFormat()
public void setSerializationNullFormat(String format)
public boolean isNotPartitioned()
public boolean isPartitioned()
public org.apache.hadoop.fs.Path getTblDir()
public void setTblDir(org.apache.hadoop.fs.Path tblDir)
tblDir
- the tblDir to setpublic TableDesc getTblDesc()
public void setTblDesc(TableDesc tblDesc)
tblDesc
- the tblDesc to setpublic ArrayList<org.apache.hadoop.fs.Path> getPartDir()
public void setPartDir(ArrayList<org.apache.hadoop.fs.Path> partDir)
partDir
- the partDir to setpublic ArrayList<PartitionDesc> getPartDesc()
public List<org.apache.hadoop.fs.Path> getPathLists()
public ArrayList<PartitionDesc> getPartDescOrderedByPartDir()
public List<PartitionDesc> getPartDescs(List<org.apache.hadoop.fs.Path> paths)
public void setPartDesc(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 void setVectorizationExamined(boolean vectorizationExamined)
public boolean getVectorizationExamined()
public FetchWork.FetchExplainVectorization getMapExplainVectorization()
Copyright © 2021 The Apache Software Foundation. All rights reserved.