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

Field Summary

Fields

Modifier and Type	Field and Description
static String	FETCH_OPERATOR_DIRECTORY_LIST

Constructor Summary

Constructors

Constructor and Description
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

Methods

Modifier and Type	Method and Description
void	clearFetchContext() Clear the context, if anything needs to be done.
protected void	flushRow()
InspectableObject	getNextRow() Get the next row.
protected org.apache.hadoop.hive.ql.exec.FetchOperator.FetchInputFormatSplit[]	getNextSplits()
ObjectInspector	getOutputObjectInspector() returns output ObjectInspector, never null
FetchWork	getWork()
boolean	pushRow() Get the next row and push down it to operator tree.
protected void	pushRow(InspectableObject row)
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

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

Field Detail

FETCH_OPERATOR_DIRECTORY_LIST

public static final String FETCH_OPERATOR_DIRECTORY_LIST

See Also:

Constant Field Values

Constructor Detail

FetchOperator

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

Throws:

HiveException

FetchOperator

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

Throws:

HiveException

Method Detail

getWork

public FetchWork getWork()

setWork

public void setWork(FetchWork work)

getNextSplits

protected org.apache.hadoop.hive.ql.exec.FetchOperator.FetchInputFormatSplit[] getNextSplits()
                                                                                      throws Exception

Throws:

Exception

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

pushRow

protected void pushRow(InspectableObject row)
                throws HiveException

Throws:

HiveException

flushRow

protected void flushRow()
                 throws HiveException

Throws:

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()

returns output ObjectInspector, never null