public class ReExecDriver extends Object implements IDriver
Modifier and Type | Field and Description |
---|---|
protected Driver |
coreDriver |
Constructor and Description |
---|
ReExecDriver(QueryState queryState,
String userName,
QueryInfo queryInfo,
ArrayList<IReExecutionPlugin> plugins) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
int |
compile(String string) |
CommandProcessorResponse |
compileAndRespond(String statement) |
void |
destroy() |
boolean |
firstExecution() |
HiveConf |
getConf() |
Context |
getContext() |
FetchTask |
getFetchTask() |
QueryPlan |
getPlan() |
QueryDisplay |
getQueryDisplay() |
boolean |
getResults(List res) |
Schema |
getSchema() |
boolean |
hasResultSet() |
boolean |
isFetchingTable() |
protected void |
prepareToReExecute() |
void |
resetFetch() |
CommandProcessorResponse |
run() |
CommandProcessorResponse |
run(String command) |
void |
setMaxRows(int maxRows) |
void |
setOperationId(String guid64) |
void |
setStatsSource(StatsSource statsSource) |
protected Driver coreDriver
public ReExecDriver(QueryState queryState, String userName, QueryInfo queryInfo, ArrayList<IReExecutionPlugin> plugins)
public boolean firstExecution()
public CommandProcessorResponse compileAndRespond(String statement)
compileAndRespond
in interface IDriver
public QueryDisplay getQueryDisplay()
getQueryDisplay
in interface IDriver
public void setOperationId(String guid64)
setOperationId
in interface IDriver
public CommandProcessorResponse run()
public CommandProcessorResponse run(String command)
run
in interface IDriver
run
in interface CommandProcessor
protected void prepareToReExecute()
public boolean getResults(List res) throws IOException
getResults
in interface IDriver
IOException
public void setMaxRows(int maxRows)
setMaxRows
in interface IDriver
public FetchTask getFetchTask()
getFetchTask
in interface IDriver
public boolean isFetchingTable()
isFetchingTable
in interface IDriver
public void resetFetch() throws IOException
resetFetch
in interface IDriver
IOException
public void close()
close
in interface AutoCloseable
close
in interface IDriver
public final Context getContext()
getContext
in interface IDriver
public void setStatsSource(StatsSource statsSource)
public boolean hasResultSet()
hasResultSet
in interface IDriver
Copyright © 2022 The Apache Software Foundation. All rights reserved.