org.apache.hadoop.hive.ql.reexec

Interface IReExecutionPlugin

All Known Implementing Classes:

ReExecutionOverlayPlugin, ReOptimizePlugin

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public interface IReExecutionPlugin

Defines an interface for re-execution logics. FIXME: rethink methods.

Method Summary

Modifier and Type	Method and Description
void	afterExecute(PlanMapper planMapper, boolean successfull)
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 oldPlanMapper, PlanMapper newPlanMapper) The query have failed; and have been recompiled - does this plugin advises to re-execute it again?

Method Detail

initialize

void initialize(Driver driver)

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

beforeExecute

void beforeExecute(int executionIndex,
                   boolean explainReOptimization)

Called before executing the query.

shouldReExecute

boolean shouldReExecute(int executionNum)

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

prepareToReExecute

void prepareToReExecute()

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

shouldReExecute

boolean shouldReExecute(int executionNum,
                        PlanMapper oldPlanMapper,
                        PlanMapper newPlanMapper)

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

afterExecute

void afterExecute(PlanMapper planMapper,
                  boolean successfull)