@DeveloperApi
public interface ExecutorPlugin
SparkPlugin
.Modifier and Type | Method and Description |
---|---|
default void |
init(PluginContext ctx,
java.util.Map<String,String> extraConf)
Initialize the executor plugin.
|
default void |
shutdown()
Clean up and terminate this plugin.
|
default void init(PluginContext ctx, java.util.Map<String,String> extraConf)
When a Spark plugin provides an executor plugin, this method will be called during the initialization of the executor process. It will block executor initialization until it returns.
Executor plugins that publish metrics should register all metrics with the context's
registry (PluginContext.metricRegistry()
) when this method is called. Metrics
registered afterwards are not guaranteed to show up.
ctx
- Context information for the executor where the plugin is running.extraConf
- Extra configuration provided by the driver component during its
initialization.default void shutdown()
This method is called during the executor shutdown phase, and blocks executor shutdown.