org.apache.hadoop.hive.ql.exec

Class FetchOperator

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

public class FetchOperator
extends java.lang.Object
implements java.io.Serializable

FetchTask implementation.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Operator<?>	operator

Constructor Summary

Constructors

Constructor and Description
FetchOperator()
FetchOperator(FetchWork work, JobConf job)
FetchOperator(FetchWork work, JobConf job, Operator<?> operator, java.util.List<VirtualColumn> vcCols)

Method Summary

Modifier and Type	Method and Description
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.
protected void	pushRow(InspectableObject row)
void	setCurrPart(PartitionDesc currPart)
void	setCurrTbl(TableDesc currTbl)
void	setSplitNum(int splitNum)
void	setTblDataDone(boolean tblDataDone)
void	setupContext(java.util.List<Path> paths) used for bucket map join
void	setWork(FetchWork work)

Methods inherited from class java.lang.Object

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

Field Detail

operator

protected Operator<?> operator

Constructor Detail

FetchOperator

public FetchOperator()

FetchOperator

public FetchOperator(FetchWork work,
                     JobConf job)

FetchOperator

public FetchOperator(FetchWork work,
                     JobConf job,
                     Operator<?> operator,
                     java.util.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 java.io.IOException,
                       HiveException

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

Throws:

java.io.IOException

HiveException

pushRow

protected void pushRow(InspectableObject row)
                throws HiveException

Throws:

HiveException

getNextRow

public InspectableObject getNextRow()
                             throws java.io.IOException

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

Throws:

java.io.IOException

clearFetchContext

public void clearFetchContext()
                       throws HiveException

Clear the context, if anything needs to be done.

Throws:

HiveException

setupContext

public void setupContext(java.util.List<Path> paths)

used for bucket map join

getOutputObjectInspector

public ObjectInspector getOutputObjectInspector()
                                         throws HiveException

returns output ObjectInspector, never null

Throws:

HiveException