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

Modifier and Type	Method and Description
void	clearFetchContext() Clear the context, if anything needs to be done.
void	closeOperator()
protected void	flushRow()
static org.apache.hadoop.mapred.InputFormat	getInputFormatFromCache(Class<? extends org.apache.hadoop.mapred.InputFormat> inputFormatClass, org.apache.hadoop.conf.Configuration conf)
org.apache.hadoop.conf.Configuration	getJobConf()
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	setValidWriteIdList(String writeIdStr)
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

setValidWriteIdList

public void setValidWriteIdList(String writeIdStr)

getWork

public FetchWork getWork()

setWork

public void setWork(FetchWork work)

getInputFormatFromCache

public static org.apache.hadoop.mapred.InputFormat getInputFormatFromCache(Class<? extends org.apache.hadoop.mapred.InputFormat> inputFormatClass,
                                                                           org.apache.hadoop.conf.Configuration conf)
                                                                    throws IOException

Throws:

IOException

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

closeOperator

public void closeOperator()
                   throws HiveException

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

getJobConf

public org.apache.hadoop.conf.Configuration getJobConf()