org.apache.hadoop.hive.ql.plan
Class FetchWork

java.lang.Object
  org.apache.hadoop.hive.ql.plan.FetchWork

All Implemented Interfaces:

Serializable

public class FetchWork
extends Object
implements Serializable

FetchWork.

See Also:

Serialized Form

Constructor Summary

FetchWork()

FetchWork(List<List<Object>> rowsComputedFromStats, ObjectInspector 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)

Method Summary

int	getLeastNumRows()
int	getLimit()
ArrayList<PartitionDesc>	getPartDesc()
ArrayList<PartitionDesc>	getPartDescOrderedByPartDir() Get Partition descriptors in sorted (ascending) order of partition directory
List<PartitionDesc>	getPartDescs(List<org.apache.hadoop.fs.Path> paths)
ArrayList<org.apache.hadoop.fs.Path>	getPartDir()
List<List<Object>>	getRowsComputedUsingStats()
String	getSerializationNullFormat()
ListSinkOperator	getSink()
Operator<?>	getSource()
SplitSample	getSplitSample()
ObjectInspector	getStatRowOI()
TableDesc	getTblDesc()
org.apache.hadoop.fs.Path	getTblDir()
void	initializeForFetch()
boolean	isNotPartitioned()
boolean	isPartitioned()
void	setLeastNumRows(int leastNumRows)
void	setLimit(int limit)
void	setPartDesc(ArrayList<PartitionDesc> partDesc)
void	setPartDir(ArrayList<org.apache.hadoop.fs.Path> partDir)
void	setSerializationNullFormat(String format)
void	setSink(ListSinkOperator sink)
void	setSource(Operator<?> source)
void	setSplitSample(SplitSample splitSample)
void	setTblDesc(TableDesc tblDesc)
void	setTblDir(org.apache.hadoop.fs.Path tblDir)
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

FetchWork

public FetchWork()

FetchWork

public FetchWork(List<List<Object>> rowsComputedFromStats,
                 ObjectInspector statRowOI)

FetchWork

public FetchWork(org.apache.hadoop.fs.Path tblDir,
                 TableDesc tblDesc)

FetchWork

public FetchWork(org.apache.hadoop.fs.Path tblDir,
                 TableDesc tblDesc,
                 int limit)

FetchWork

public FetchWork(List<org.apache.hadoop.fs.Path> partDir,
                 List<PartitionDesc> partDesc,
                 TableDesc tblDesc)

FetchWork

public FetchWork(List<org.apache.hadoop.fs.Path> partDir,
                 List<PartitionDesc> partDesc,
                 TableDesc tblDesc,
                 int limit)

Method Detail

getStatRowOI

public ObjectInspector getStatRowOI()

getRowsComputedUsingStats

public List<List<Object>> getRowsComputedUsingStats()

initializeForFetch

public void initializeForFetch()

getSerializationNullFormat

public String getSerializationNullFormat()

setSerializationNullFormat

public void setSerializationNullFormat(String format)

isNotPartitioned

public boolean isNotPartitioned()

isPartitioned

public boolean isPartitioned()

getTblDir

public org.apache.hadoop.fs.Path getTblDir()

Returns:

the tblDir

setTblDir

public void setTblDir(org.apache.hadoop.fs.Path tblDir)

Parameters:

tblDir - the tblDir to set

getTblDesc

public TableDesc getTblDesc()

Returns:

the tblDesc

setTblDesc

public void setTblDesc(TableDesc tblDesc)

Parameters:

tblDesc - the tblDesc to set

getPartDir

public ArrayList<org.apache.hadoop.fs.Path> getPartDir()

Returns:

the partDir

setPartDir

public void setPartDir(ArrayList<org.apache.hadoop.fs.Path> partDir)

Parameters:

partDir - the partDir to set

getPartDesc

public ArrayList<PartitionDesc> getPartDesc()

Returns:

the partDesc

getPartDescOrderedByPartDir

public ArrayList<PartitionDesc> getPartDescOrderedByPartDir()

Get Partition descriptors in sorted (ascending) order of partition directory

Returns:

the partDesc array list

getPartDescs

public List<PartitionDesc> getPartDescs(List<org.apache.hadoop.fs.Path> paths)

Returns:

the partDescs for paths

setPartDesc

public void setPartDesc(ArrayList<PartitionDesc> partDesc)

Parameters:

partDesc - the partDesc to set

getLimit

public int getLimit()

Returns:

the limit

setLimit

public void setLimit(int limit)

Parameters:

limit - the limit to set

getLeastNumRows

public int getLeastNumRows()

setLeastNumRows

public void setLeastNumRows(int leastNumRows)

getSource

public Operator<?> getSource()

setSource

public void setSource(Operator<?> source)

getSink

public ListSinkOperator getSink()

setSink

public void setSink(ListSinkOperator sink)

setSplitSample

public void setSplitSample(SplitSample splitSample)

getSplitSample

public SplitSample getSplitSample()

toString

public String toString()

Overrides:

toString in class Object