|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.hive.ql.exec.Task<FetchWork> org.apache.hadoop.hive.ql.exec.FetchTask
public class FetchTask
FetchTask implementation.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.exec.Task |
---|
Task.FeedType |
Field Summary |
---|
Fields inherited from class org.apache.hadoop.hive.ql.exec.Task |
---|
BACKUP_COMMON_JOIN, COMMON_JOIN, CONVERTED_MAPJOIN, CONVERTED_MAPJOIN_LOCAL, CONVERTED_SORTMERGEJOIN, HINTED_MAPJOIN, HINTED_MAPJOIN_LOCAL, MAPJOIN_ONLY_NOBACKUP, NO_TAG, taskCounters, taskHandle |
Constructor Summary | |
---|---|
FetchTask()
|
Method Summary | |
---|---|
void |
clearFetch()
Clear the Fetch Operator. |
int |
execute(DriverContext driverContext)
This method is overridden in each Task. |
boolean |
fetch(List res)
|
int |
getMaxRows()
Return the maximum number of rows returned by fetch. |
String |
getName()
Gets the name of the node. |
TableDesc |
getTblDesc()
Return the tableDesc of the fetchWork. |
org.apache.hadoop.hive.ql.plan.api.StageType |
getType()
Should be overridden to return the type of the specific task among the types in StageType. |
void |
initialize(HiveConf conf,
QueryPlan queryPlan,
DriverContext ctx)
|
void |
setMaxRows(int maxRows)
Set the maximum number of rows returned by fetch. |
Methods inherited from class java.lang.Object |
---|
getClass, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public FetchTask()
Method Detail |
---|
public void initialize(HiveConf conf, QueryPlan queryPlan, DriverContext ctx)
initialize
in class Task<FetchWork>
public int execute(DriverContext driverContext)
Task
public TableDesc getTblDesc()
public int getMaxRows()
public void setMaxRows(int maxRows)
public boolean fetch(List res) throws IOException, CommandNeedRetryException
IOException
CommandNeedRetryException
public org.apache.hadoop.hive.ql.plan.api.StageType getType()
Task
getType
in class Task<FetchWork>
public String getName()
Node
getName
in interface Node
public void clearFetch() throws HiveException
HiveException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |