Package step.engine.plugins
Class AbstractExecutionEnginePlugin
java.lang.Object
step.core.plugins.AbstractPlugin
step.engine.plugins.AbstractExecutionEnginePlugin
- All Implemented Interfaces:
ExecutionCallbacks
,step.core.plugins.OptionalPlugin
,ExecutionEnginePlugin
- Direct Known Subclasses:
BaseArtefactPlugin
,BasePlugin
,CompositeFunctionTypePlugin
,FunctionPlugin
,GeneralScriptFunctionPlugin
,LocalCompositeFunctionPlugin
,LocalFunctionPlugin
,LocalRepositoryPlugin
,MeasurementPlugin
,ParameterManagerPlugin
,QuotaManagerPlugin
,ThreadManagerPlugin
,ThreadPoolPlugin
,TimeSeriesExecutionPlugin
,ViewPlugin
public abstract class AbstractExecutionEnginePlugin
extends step.core.plugins.AbstractPlugin
implements ExecutionEnginePlugin
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
afterExecutionEnd
(ExecutionContext context) void
afterFunctionExecution
(ExecutionContext context, ReportNode node, Function function, step.functions.io.Output<jakarta.json.JsonObject> output) This hook is called immediately after aFunction
is executed in CallFunctionHandler.void
Deprecated.void
afterReportNodeExecution
(ExecutionContext context, ReportNode node) void
Deprecated.void
afterReportNodeSkeletonCreation
(ExecutionContext context, ReportNode node) void
associateThread
(ExecutionContext context, Thread thread) void
associateThread
(ExecutionContext context, Thread thread, long parentThreadId) void
beforeExecutionEnd
(ExecutionContext context) void
beforeFunctionExecution
(ExecutionContext context, ReportNode node, Function function) void
beforePlanImport
(ExecutionContext context) void
Deprecated.void
beforeReportNodeExecution
(ExecutionContext context, ReportNode node) void
executionStart
(ExecutionContext context) void
initializeExecutionContext
(ExecutionEngineContext executionEngineContext, ExecutionContext executionContext) void
initializeExecutionEngineContext
(AbstractExecutionEngineContext parentContext, ExecutionEngineContext executionEngineContext) void
onErrorContributionRemoval
(ExecutionContext context, ReportNode node) void
onReportNodeRemoval
(ExecutionContext context, ReportNode node) void
unassociateThread
(ExecutionContext context, Thread thread) Methods inherited from class step.core.plugins.AbstractPlugin
toString, validate
-
Constructor Details
-
AbstractExecutionEnginePlugin
public AbstractExecutionEnginePlugin()
-
-
Method Details
-
initializeExecutionEngineContext
public void initializeExecutionEngineContext(AbstractExecutionEngineContext parentContext, ExecutionEngineContext executionEngineContext) - Specified by:
initializeExecutionEngineContext
in interfaceExecutionEnginePlugin
-
initializeExecutionContext
public void initializeExecutionContext(ExecutionEngineContext executionEngineContext, ExecutionContext executionContext) - Specified by:
initializeExecutionContext
in interfaceExecutionEnginePlugin
-
executionStart
- Specified by:
executionStart
in interfaceExecutionCallbacks
-
beforeExecutionEnd
- Specified by:
beforeExecutionEnd
in interfaceExecutionCallbacks
-
afterExecutionEnd
- Specified by:
afterExecutionEnd
in interfaceExecutionCallbacks
-
afterReportNodeSkeletonCreation
Deprecated. -
beforeReportNodeExecution
Deprecated. -
afterReportNodeExecution
Deprecated. -
afterReportNodeSkeletonCreation
- Specified by:
afterReportNodeSkeletonCreation
in interfaceExecutionCallbacks
-
beforeReportNodeExecution
- Specified by:
beforeReportNodeExecution
in interfaceExecutionCallbacks
-
afterReportNodeExecution
- Specified by:
afterReportNodeExecution
in interfaceExecutionCallbacks
-
onReportNodeRemoval
- Specified by:
onReportNodeRemoval
in interfaceExecutionCallbacks
-
onErrorContributionRemoval
- Specified by:
onErrorContributionRemoval
in interfaceExecutionCallbacks
-
associateThread
- Specified by:
associateThread
in interfaceExecutionCallbacks
-
associateThread
- Specified by:
associateThread
in interfaceExecutionCallbacks
-
unassociateThread
- Specified by:
unassociateThread
in interfaceExecutionCallbacks
-
beforePlanImport
- Specified by:
beforePlanImport
in interfaceExecutionCallbacks
-
beforeFunctionExecution
Description copied from interface:ExecutionCallbacks
This hook is called before aFunction
is executed in CallFunctionHandler just after theFunction
has been resolved The hook is also called in simulation mode- Specified by:
beforeFunctionExecution
in interfaceExecutionCallbacks
- Parameters:
context
- theExecutionContext
function
- the resolvedFunction
that will be executed
-
afterFunctionExecution
public void afterFunctionExecution(ExecutionContext context, ReportNode node, Function function, step.functions.io.Output<jakarta.json.JsonObject> output) Description copied from interface:ExecutionCallbacks
This hook is called immediately after aFunction
is executed in CallFunctionHandler. TheReportNode
provided as argument is therefore not reflecting the final status. If you need the final status after CallFunction execution use the hookExecutionCallbacks.afterReportNodeExecution(ExecutionContext, ReportNode)
instead. The hook is also called in simulation mode.- Specified by:
afterFunctionExecution
in interfaceExecutionCallbacks
- Parameters:
context
- theExecutionContext
function
- theFunction
that has been executedoutput
- the resultOutput
of the execution
-