org.apache.hadoop.hive.ql.reexec

Class ReExecDriver

java.lang.Object

org.apache.hadoop.hive.ql.reexec.ReExecDriver

All Implemented Interfaces:

AutoCloseable, IDriver, CommandProcessor

public class ReExecDriver
extends Object
implements IDriver

Enables to use re-execution logics. Covers the IDriver interface, handles query re-execution; and asks clear questions from the underlying re-execution plugins.

Field Summary

Fields

Modifier and Type	Field and Description
protected Driver	coreDriver

Constructor Summary

Constructors

Constructor and Description
ReExecDriver(QueryState queryState, String userName, QueryInfo queryInfo, ArrayList<IReExecutionPlugin> plugins)

Method Summary

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)
org.apache.hadoop.hive.metastore.api.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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

coreDriver

protected Driver coreDriver

Constructor Detail

ReExecDriver

public ReExecDriver(QueryState queryState,
                    String userName,
                    QueryInfo queryInfo,
                    ArrayList<IReExecutionPlugin> plugins)

Method Detail

getConf

public HiveConf getConf()

Specified by:

getConf in interface IDriver

firstExecution

public boolean firstExecution()

compile

public int compile(String string)

Specified by:

compile in interface IDriver

compileAndRespond

public CommandProcessorResponse compileAndRespond(String statement)

Specified by:

compileAndRespond in interface IDriver

getPlan

public QueryPlan getPlan()

Specified by:

getPlan in interface IDriver

getQueryDisplay

public QueryDisplay getQueryDisplay()

Specified by:

getQueryDisplay in interface IDriver

setOperationId

public void setOperationId(String guid64)

Specified by:

setOperationId in interface IDriver

run

public CommandProcessorResponse run()

Specified by:

run in interface IDriver

run

public CommandProcessorResponse run(String command)

Specified by:

run in interface IDriver

Specified by:

run in interface CommandProcessor

prepareToReExecute

protected void prepareToReExecute()

getResults

public boolean getResults(List res)
                   throws IOException

Specified by:

getResults in interface IDriver

Throws:

IOException

setMaxRows

public void setMaxRows(int maxRows)

Specified by:

setMaxRows in interface IDriver

getFetchTask

public FetchTask getFetchTask()

Specified by:

getFetchTask in interface IDriver

getSchema

public org.apache.hadoop.hive.metastore.api.Schema getSchema()

Specified by:

getSchema in interface IDriver

isFetchingTable

public boolean isFetchingTable()

Specified by:

isFetchingTable in interface IDriver

resetFetch

public void resetFetch()
                throws IOException

Specified by:

resetFetch in interface IDriver

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface IDriver

destroy

public void destroy()

Specified by:

destroy in interface IDriver

getContext

public final Context getContext()

Specified by:

getContext in interface IDriver

setStatsSource

public void setStatsSource(StatsSource statsSource)

hasResultSet

public boolean hasResultSet()

Specified by:

hasResultSet in interface IDriver