org.apache.hadoop.hive.ql.exec
Class FetchOperator

java.lang.Object
  org.apache.hadoop.hive.ql.exec.FetchOperator

All Implemented Interfaces:

Serializable

public class FetchOperator
extends Object
implements Serializable

FetchTask implementation.

See Also:

Serialized Form

Constructor Summary

FetchOperator()

FetchOperator(FetchWork work, org.apache.hadoop.mapred.JobConf job)

FetchOperator(FetchWork work, org.apache.hadoop.mapred.JobConf job, Operator<?> operator, List<VirtualColumn> vcCols)

Method Summary

void	clearFetchContext() Clear the context, if anything needs to be done.
PartitionDesc	getCurrPart()
TableDesc	getCurrTbl()
InspectableObject	getNextRow() Get the next row.
ObjectInspector	getOutputObjectInspector() returns output ObjectInspector, never null
int	getSplitNum()
FetchWork	getWork()
boolean	isEmptyTable()
boolean	isTblDataDone()
boolean	pushRow() Get the next row and push down it to operator tree.
void	setCurrPart(PartitionDesc currPart)
void	setCurrTbl(TableDesc currTbl)
void	setSplitNum(int splitNum)
void	setTblDataDone(boolean tblDataDone)
void	setupContext(List<org.apache.hadoop.fs.Path> paths) used for bucket map join
void	setWork(FetchWork work)

Methods inherited from class java.lang.Object

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

Constructor Detail

FetchOperator

public FetchOperator()

FetchOperator

public FetchOperator(FetchWork work,
                     org.apache.hadoop.mapred.JobConf job)

FetchOperator

public FetchOperator(FetchWork work,
                     org.apache.hadoop.mapred.JobConf job,
                     Operator<?> operator,
                     List<VirtualColumn> vcCols)

Method Detail

getWork

public FetchWork getWork()

setWork

public void setWork(FetchWork work)

getSplitNum

public int getSplitNum()

setSplitNum

public void setSplitNum(int splitNum)

getCurrPart

public PartitionDesc getCurrPart()

setCurrPart

public void setCurrPart(PartitionDesc currPart)

getCurrTbl

public TableDesc getCurrTbl()

setCurrTbl

public void setCurrTbl(TableDesc currTbl)

isTblDataDone

public boolean isTblDataDone()

setTblDataDone

public void setTblDataDone(boolean tblDataDone)

isEmptyTable

public boolean isEmptyTable()

pushRow

public boolean pushRow()
                throws IOException,
                       HiveException

Get the next row and push down it to operator tree. Currently only used by FetchTask.

Throws:

IOException

HiveException

getNextRow

public InspectableObject getNextRow()
                             throws IOException

Get the next row. The fetch context is modified appropriately.

Throws:

IOException

clearFetchContext

public void clearFetchContext()
                       throws HiveException

Clear the context, if anything needs to be done.

Throws:

HiveException

setupContext

public void setupContext(List<org.apache.hadoop.fs.Path> paths)

used for bucket map join

getOutputObjectInspector

public ObjectInspector getOutputObjectInspector()
                                         throws HiveException

returns output ObjectInspector, never null

Throws:

HiveException