|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.hive.ql.Driver
public class Driver
Constructor Summary | |
---|---|
Driver()
|
|
Driver(HiveConf conf)
for backwards compatibility with current tests |
|
Driver(HiveConf conf,
String userName)
|
Method Summary | |
---|---|
int |
close()
|
int |
compile(String command)
Compile a new query. |
int |
compile(String command,
boolean resetTaskIds)
Compile a new query, but potentially reset taskID counter. |
CommandProcessorResponse |
compileAndRespond(String command)
|
void |
destroy()
|
int |
execute()
|
org.apache.hadoop.mapred.ClusterStatus |
getClusterStatus()
Return the status information about the Map-Reduce cluster |
String |
getErrorMsg()
|
int |
getMaxRows()
Return the maximum number of rows returned by getResults |
QueryPlan |
getPlan()
|
org.apache.hadoop.hive.ql.plan.api.Query |
getQueryPlan()
|
boolean |
getResults(List res)
|
org.apache.hadoop.hive.metastore.api.Schema |
getSchema()
|
static org.apache.hadoop.hive.metastore.api.Schema |
getSchema(BaseSemanticAnalyzer sem,
HiveConf conf)
Get a Schema with fields represented with native Hive types |
org.apache.hadoop.hive.metastore.api.Schema |
getThriftSchema()
Get a Schema with fields represented with Thrift DDL types |
int |
getTryCount()
|
boolean |
hasReduceTasks(List<Task<? extends Serializable>> tasks)
|
void |
init()
|
boolean |
isFetchingTable()
|
void |
resetFetch()
|
void |
restoreSession(org.apache.hadoop.hive.ql.Driver.QueryState qs)
|
CommandProcessorResponse |
run()
|
CommandProcessorResponse |
run(String command)
|
CommandProcessorResponse |
run(String command,
boolean alreadyCompiled)
|
void |
saveSession(org.apache.hadoop.hive.ql.Driver.QueryState qs)
|
void |
setMaxRows(int maxRows)
Set the maximum number of rows returned by getResults |
void |
setTryCount(int tryCount)
|
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public Driver(HiveConf conf)
public Driver(HiveConf conf, String userName)
public Driver()
Method Detail |
---|
public void init()
init
in interface CommandProcessor
public org.apache.hadoop.mapred.ClusterStatus getClusterStatus() throws Exception
Exception
public org.apache.hadoop.hive.metastore.api.Schema getSchema()
public static org.apache.hadoop.hive.metastore.api.Schema getSchema(BaseSemanticAnalyzer sem, HiveConf conf)
public org.apache.hadoop.hive.metastore.api.Schema getThriftSchema() throws Exception
Exception
public int getMaxRows()
public void setMaxRows(int maxRows)
public boolean hasReduceTasks(List<Task<? extends Serializable>> tasks)
public int compile(String command)
command
- The SQL query to compile.public void saveSession(org.apache.hadoop.hive.ql.Driver.QueryState qs)
public void restoreSession(org.apache.hadoop.hive.ql.Driver.QueryState qs)
public int compile(String command, boolean resetTaskIds)
command
- The HiveQL query to compileresetTaskIds
- Resets taskID counter if true.
public QueryPlan getPlan()
public CommandProcessorResponse run(String command) throws CommandNeedRetryException
run
in interface CommandProcessor
CommandNeedRetryException
public CommandProcessorResponse run() throws CommandNeedRetryException
CommandNeedRetryException
public CommandProcessorResponse run(String command, boolean alreadyCompiled) throws CommandNeedRetryException
CommandNeedRetryException
public CommandProcessorResponse compileAndRespond(String command)
public int execute() throws CommandNeedRetryException
CommandNeedRetryException
public boolean isFetchingTable()
public boolean getResults(List res) throws IOException, CommandNeedRetryException
IOException
CommandNeedRetryException
public void resetFetch() throws IOException
IOException
public int getTryCount()
public void setTryCount(int tryCount)
public int close()
public void destroy()
public org.apache.hadoop.hive.ql.plan.api.Query getQueryPlan() throws IOException
IOException
public String getErrorMsg()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |