Package org.apache.flink.core.plugin
Class DefaultPluginManager
- java.lang.Object
-
- org.apache.flink.core.plugin.DefaultPluginManager
-
- All Implemented Interfaces:
PluginManager
@Internal @ThreadSafe public class DefaultPluginManager extends Object implements PluginManager
Default implementation ofPluginManager
.
-
-
Constructor Summary
Constructors Constructor Description DefaultPluginManager(Collection<PluginDescriptor> pluginDescriptors, ClassLoader parentClassLoader, String[] alwaysParentFirstPatterns)
DefaultPluginManager(Collection<PluginDescriptor> pluginDescriptors, String[] alwaysParentFirstPatterns)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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.String
toString()
-
-
-
Constructor Detail
-
DefaultPluginManager
public DefaultPluginManager(Collection<PluginDescriptor> pluginDescriptors, String[] alwaysParentFirstPatterns)
-
DefaultPluginManager
public DefaultPluginManager(Collection<PluginDescriptor> pluginDescriptors, ClassLoader parentClassLoader, String[] alwaysParentFirstPatterns)
-
-
Method Detail
-
load
public <P> Iterator<P> load(Class<P> service)
Description copied from interface:PluginManager
Returns in iterator over all available implementations of the given service interface (SPI) in all the plugins known to this plugin manager instance.- Specified by:
load
in interfacePluginManager
- 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.
-
-