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 of PluginManager.

Constructor Summary

Constructors

Constructor and Description
DefaultPluginManager(Collection<PluginDescriptor> pluginDescriptors, ClassLoader parentClassLoader, String[] alwaysParentFirstPatterns)
DefaultPluginManager(Collection<PluginDescriptor> pluginDescriptors, String[] alwaysParentFirstPatterns)

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.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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 interface PluginManager

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.

toString

public String toString()

Overrides:

toString in class Object