co.cask.cdap.data2.datafabric.dataset.type

Class DirectoryClassLoaderProvider

java.lang.Object

co.cask.cdap.data2.datafabric.dataset.type.DirectoryClassLoaderProvider

All Implemented Interfaces:

DatasetClassLoaderProvider, Closeable, AutoCloseable

public class DirectoryClassLoaderProvider
extends Object
implements DatasetClassLoaderProvider

Creates a ClassLoader for a DatasetModuleMeta by unpacking the dataset jar and creating a DirectoryClassLoader over the unpacked jar. Classloaders are cached, and unpacked directories are cleaned up when the provider is closed. Note that this means changes to dataset code are not picked up, as the assumption is that this provider is created once at the start of a program run and closed at the end.

Constructor Summary

Constructors

Constructor and Description
DirectoryClassLoaderProvider(CConfiguration cConf, LocationFactory locationFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
ClassLoader	get(DatasetModuleMeta moduleMeta, ClassLoader parentClassLoader) Get the classloader for a specific dataset module.

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectoryClassLoaderProvider

public DirectoryClassLoaderProvider(CConfiguration cConf,
                            LocationFactory locationFactory)

Method Detail

get

public ClassLoader get(DatasetModuleMeta moduleMeta,
              ClassLoader parentClassLoader)
                throws IOException

Description copied from interface: DatasetClassLoaderProvider

Get the classloader for a specific dataset module.

Specified by:

get in interface DatasetClassLoaderProvider

Parameters:

moduleMeta - the metadata for the dataset module to get a classloader for

parentClassLoader - the class loader to use as the parent

Returns:

classloader for the given dataset module

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException