public class FetchOperator extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
static String |
FETCH_OPERATOR_DIRECTORY_LIST |
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) |
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) |
public static final String FETCH_OPERATOR_DIRECTORY_LIST
public FetchOperator(FetchWork work, org.apache.hadoop.mapred.JobConf job) throws HiveException
HiveException
public FetchOperator(FetchWork work, org.apache.hadoop.mapred.JobConf job, Operator<?> operator, List<VirtualColumn> vcCols) throws HiveException
HiveException
public void setValidWriteIdList(String writeIdStr)
public FetchWork getWork()
public void setWork(FetchWork work)
public static org.apache.hadoop.mapred.InputFormat getInputFormatFromCache(Class<? extends org.apache.hadoop.mapred.InputFormat> inputFormatClass, org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
protected org.apache.hadoop.hive.ql.exec.FetchOperator.FetchInputFormatSplit[] getNextSplits() throws Exception
Exception
public boolean pushRow() throws IOException, HiveException
IOException
HiveException
protected void pushRow(InspectableObject row) throws HiveException
HiveException
protected void flushRow() throws HiveException
HiveException
public InspectableObject getNextRow() throws IOException
IOException
public void clearFetchContext() throws HiveException
HiveException
public void closeOperator() throws HiveException
HiveException
public void setupContext(List<org.apache.hadoop.fs.Path> paths)
public ObjectInspector getOutputObjectInspector()
public org.apache.hadoop.conf.Configuration getJobConf()
Copyright © 2022 The Apache Software Foundation. All rights reserved.