public class ReExecutionDagSubmitPlugin extends Object implements IReExecutionPlugin
Constructor and Description |
---|
ReExecutionDagSubmitPlugin() |
Modifier and Type | Method and Description |
---|---|
void |
initialize(Driver driver)
Called when the
Driver is being initialized
The plugin may add hooks/etc to tap into the system. |
boolean |
shouldReExecute(int executionNum)
The query have failed, does this plugin advises to re-execute it again?
|
boolean |
shouldReExecuteAfterCompile(int executionNum,
PlanMapper pm1,
PlanMapper pm2)
The query has failed; and have been recompiled - does this plugin advises to re-execute it again?
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
afterCompile, afterExecute, beforeCompile, beforeExecute, prepareToReCompile, prepareToReExecute, shouldReCompile
public void initialize(Driver driver)
IReExecutionPlugin
Driver
is being initialized
The plugin may add hooks/etc to tap into the system.initialize
in interface IReExecutionPlugin
public boolean shouldReExecuteAfterCompile(int executionNum, PlanMapper pm1, PlanMapper pm2)
IReExecutionPlugin
shouldReExecuteAfterCompile
in interface IReExecutionPlugin
public boolean shouldReExecute(int executionNum)
IReExecutionPlugin
shouldReExecute
in interface IReExecutionPlugin
Copyright © 2022 The Apache Software Foundation. All rights reserved.