org.apache.flink.core.plugin

Interface PluginManager

All Known Implementing Classes:

DefaultPluginManager

public interface PluginManager

PluginManager is responsible for managing cluster plugins which are loaded using separate class loaders so that their dependencies don't interfere with Flink's dependencies.

Method Summary

Modifier and Type	Method and Description
<P> Iterator<P>	load(Class<P> service) Returns in iterator over all available implementations of the given service interface (SPI) in all the plugins known to this plugin manager instance.

Method Detail

load

<P> Iterator<P> load(Class<P> service)

Returns in iterator over all available implementations of the given service interface (SPI) in all the plugins known to this plugin manager instance.

Type Parameters:

P - Type of the requested plugin service.

Parameters:

service - the service interface (SPI) for which implementations are requested.

Returns:

Iterator over all implementations of the given service that could be loaded from all known plugins.