org.apache.nifi.nar

Class ExtensionManager

java.lang.Object

org.apache.nifi.nar.ExtensionManager

public class ExtensionManager
extends Object

Scans through the classpath to load all FlowFileProcessors, FlowFileComparators, and ReportingTasks using the service provider API and running through all classloaders (root, NARs).

Field Summary

Fields

Modifier and Type	Field and Description
private static Map<Class,Set<Class>>	definitionMap
private static Map<String,ClassLoader>	extensionClassloaderLookup
private static org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
ExtensionManager()

Method Summary

Methods

Modifier and Type	Method and Description
static void	discoverExtensions() Loads all FlowFileProcessor, FlowFileComparator, ReportingTask class types that can be found on the bootstrap classloader and by creating classloaders for all NARs found within the classpath.
static ClassLoader	getClassLoader(String classType) Determines the effective classloader for classes of the given type.
static Set<Class>	getExtensions(Class<?> definition)
private static void	loadExtensions(ClassLoader classLoader) Loads extensions from the specified class loader.
static void	logClassLoaderMapping()
private static void	registerServiceClass(Class<?> type, Map<String,ClassLoader> classloaderMap, ClassLoader classLoader, Set<Class> classes) Registers extension for the specified type from the specified ClassLoader.

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final org.slf4j.Logger logger

definitionMap

private static final Map<Class,Set<Class>> definitionMap

extensionClassloaderLookup

private static final Map<String,ClassLoader> extensionClassloaderLookup

Constructor Detail

ExtensionManager

public ExtensionManager()

Method Detail

discoverExtensions

public static void discoverExtensions()

Loads all FlowFileProcessor, FlowFileComparator, ReportingTask class types that can be found on the bootstrap classloader and by creating classloaders for all NARs found within the classpath.

loadExtensions

private static void loadExtensions(ClassLoader classLoader)

Loads extensions from the specified class loader.

Parameters:

classLoader - from which to load extensions

registerServiceClass

private static void registerServiceClass(Class<?> type,
                        Map<String,ClassLoader> classloaderMap,
                        ClassLoader classLoader,
                        Set<Class> classes)

Registers extension for the specified type from the specified ClassLoader.

Parameters:

type - the extension type

classloaderMap - mapping of classname to classloader

classLoader - the classloader being mapped to

classes - to map to this classloader but which come from its ancestors

getClassLoader

public static ClassLoader getClassLoader(String classType)

Determines the effective classloader for classes of the given type. If returns null it indicates the given type is not known or was not detected.

Parameters:

classType - to lookup the classloader of

Returns:

String of fully qualified class name; null if not a detected type

getExtensions

public static Set<Class> getExtensions(Class<?> definition)

logClassLoaderMapping

public static void logClassLoaderMapping()