org.apache.flink.core.plugin

Class PluginLoader

java.lang.Object

org.apache.flink.core.plugin.PluginLoader

@ThreadSafe
public class PluginLoader
extends Object

A PluginLoader is used by the PluginManager to load a single plugin. It is essentially a combination of a PluginClassLoader and ServiceLoader. This class can locate and load service implementations from the plugin for a given SPI. The PluginDescriptor, which among other information contains the resource URLs, is provided at construction.

Constructor Summary

Constructors

Constructor and Description
PluginLoader(ClassLoader pluginClassLoader)

Method Summary

Modifier and Type	Method and Description
static PluginLoader	create(PluginDescriptor pluginDescriptor, ClassLoader parentClassLoader, String[] alwaysParentFirstPatterns)
static ClassLoader	createPluginClassLoader(PluginDescriptor pluginDescriptor, ClassLoader parentClassLoader, String[] alwaysParentFirstPatterns)
<P> Iterator<P>	load(Class<P> service) Returns in iterator over all available implementations of the given service interface (SPI) for the plugin.

Methods inherited from class java.lang.Object

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

Constructor Detail

PluginLoader

@VisibleForTesting
public PluginLoader(ClassLoader pluginClassLoader)

Method Detail

createPluginClassLoader

@VisibleForTesting
public static ClassLoader createPluginClassLoader(PluginDescriptor pluginDescriptor,
                                                                     ClassLoader parentClassLoader,
                                                                     String[] alwaysParentFirstPatterns)

create

public static PluginLoader create(PluginDescriptor pluginDescriptor,
                                  ClassLoader parentClassLoader,
                                  String[] alwaysParentFirstPatterns)

load

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

Returns in iterator over all available implementations of the given service interface (SPI) for the plugin.

Type Parameters:

P - Type of the requested plugin service.

Parameters:

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

Returns:

An iterator of all implementations of the given service interface that could be loaded from the plugin.