public class FetchOperator
extends java.lang.Object
implements java.io.Serializable
Constructor and Description |
---|
FetchOperator() |
FetchOperator(FetchWork work,
JobConf job) |
FetchOperator(FetchWork work,
JobConf job,
Operator<?> operator,
java.util.List<VirtualColumn> vcCols) |
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) |
protected Operator<?> operator
public FetchOperator()
public FetchOperator(FetchWork work, JobConf job)
public FetchOperator(FetchWork work, JobConf job, Operator<?> operator, java.util.List<VirtualColumn> vcCols)
public FetchWork getWork()
public void setWork(FetchWork work)
public int getSplitNum()
public void setSplitNum(int splitNum)
public PartitionDesc getCurrPart()
public void setCurrPart(PartitionDesc currPart)
public TableDesc getCurrTbl()
public void setCurrTbl(TableDesc currTbl)
public boolean isTblDataDone()
public void setTblDataDone(boolean tblDataDone)
public boolean isEmptyTable()
public boolean pushRow() throws java.io.IOException, HiveException
java.io.IOException
HiveException
protected void pushRow(InspectableObject row) throws HiveException
HiveException
public InspectableObject getNextRow() throws java.io.IOException
java.io.IOException
public void clearFetchContext() throws HiveException
HiveException
public void setupContext(java.util.List<Path> paths)
public ObjectInspector getOutputObjectInspector() throws HiveException
HiveException
Copyright © 2012 The Apache Software Foundation