org.apache.hadoop.hive.ql.reexec

Class ReExecutionOverlayPlugin

java.lang.Object

org.apache.hadoop.hive.ql.reexec.ReExecutionOverlayPlugin

All Implemented Interfaces:

IReExecutionPlugin

public class ReExecutionOverlayPlugin
extends Object
implements IReExecutionPlugin

Re-Executes a query only adding an extra overlay

Constructor Summary

Constructors

Constructor and Description
ReExecutionOverlayPlugin()

Method Summary

Modifier and Type	Method and Description
void	afterExecute(PlanMapper planMapper, boolean success)
void	beforeExecute(int executionIndex, boolean explainReOptimization) Called before executing the query.
void	initialize(Driver driver) Called when the Driver is being initialized The plugin may add hooks/etc to tap into the system.
void	prepareToReExecute() The plugin should prepare for the re-compilaton of the query.
boolean	shouldReExecute(int executionNum) The query have failed, does this plugin advises to re-execute it again?
boolean	shouldReExecute(int executionNum, PlanMapper pm1, PlanMapper pm2) The query have failed; and have been recompiled - does this plugin advises to re-execute it again?

Methods inherited from class java.lang.Object

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

Constructor Detail

ReExecutionOverlayPlugin

public ReExecutionOverlayPlugin()

Method Detail

initialize

public void initialize(Driver driver)

Description copied from interface: IReExecutionPlugin

Called when the Driver is being initialized The plugin may add hooks/etc to tap into the system.

Specified by:

initialize in interface IReExecutionPlugin

prepareToReExecute

public void prepareToReExecute()

Description copied from interface: IReExecutionPlugin

The plugin should prepare for the re-compilaton of the query.

Specified by:

prepareToReExecute in interface IReExecutionPlugin

shouldReExecute

public boolean shouldReExecute(int executionNum)

Description copied from interface: IReExecutionPlugin

The query have failed, does this plugin advises to re-execute it again?

Specified by:

shouldReExecute in interface IReExecutionPlugin

shouldReExecute

public boolean shouldReExecute(int executionNum,
                               PlanMapper pm1,
                               PlanMapper pm2)

Description copied from interface: IReExecutionPlugin

The query have failed; and have been recompiled - does this plugin advises to re-execute it again?

Specified by:

shouldReExecute in interface IReExecutionPlugin

beforeExecute

public void beforeExecute(int executionIndex,
                          boolean explainReOptimization)

Description copied from interface: IReExecutionPlugin

Called before executing the query.

Specified by:

beforeExecute in interface IReExecutionPlugin

afterExecute

public void afterExecute(PlanMapper planMapper,
                         boolean success)

Specified by:

afterExecute in interface IReExecutionPlugin