org.apache.flink.table.resource

Class ResourceManager

java.lang.Object

org.apache.flink.table.resource.ResourceManager

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

ClientResourceManager

@Internal
public class ResourceManager
extends Object
implements Closeable

A manager for dealing with all user defined resource.

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<ResourceUri,URL>	resourceInfos
protected MutableURLClassLoader	userClassLoader

Constructor Summary

Constructors

Constructor and Description
ResourceManager(ReadableConfig config, MutableURLClassLoader userClassLoader)

Method Summary

Modifier and Type	Method and Description
void	addJarConfiguration(TableConfig tableConfig) Adds the local jar resources to the given TableConfig.
protected void	checkJarPath(Path path)
void	close()
static ResourceManager	createResourceManager(URL[] urls, ClassLoader parent, ReadableConfig config)
Set<URL>	getLocalJarResources() Get the local jars' URL.
Map<ResourceUri,URL>	getResources()
protected URL	getURLFromPath(Path path)
URLClassLoader	getUserClassLoader()
void	registerJarResources(List<ResourceUri> resourceUris) Due to anyone of the resource in list maybe fail during register, so we should stage it before actual register to guarantee transaction process.

Methods inherited from class java.lang.Object

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

Field Detail

resourceInfos

protected final Map<ResourceUri,URL> resourceInfos

userClassLoader

protected final MutableURLClassLoader userClassLoader

Constructor Detail

ResourceManager

public ResourceManager(ReadableConfig config,
                       MutableURLClassLoader userClassLoader)

Method Detail

createResourceManager

public static ResourceManager createResourceManager(URL[] urls,
                                                    ClassLoader parent,
                                                    ReadableConfig config)

registerJarResources

public void registerJarResources(List<ResourceUri> resourceUris)
                          throws IOException

Due to anyone of the resource in list maybe fail during register, so we should stage it before actual register to guarantee transaction process. If all the resources are available, register them into the ResourceManager.

Throws:

IOException

getUserClassLoader

public URLClassLoader getUserClassLoader()

getResources

public Map<ResourceUri,URL> getResources()

getLocalJarResources

public Set<URL> getLocalJarResources()

Get the local jars' URL. Return the URL corresponding to downloaded jars in the local file system for the remote jar. For the local jar, return the registered URL.

addJarConfiguration

public void addJarConfiguration(TableConfig tableConfig)

Adds the local jar resources to the given TableConfig. It implicitly considers the TableConfig.getRootConfiguration() and stores the merged result into TableConfig.getConfiguration().

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

checkJarPath

protected void checkJarPath(Path path)
                     throws IOException

Throws:

IOException

getURLFromPath

@VisibleForTesting
protected URL getURLFromPath(Path path)
                                         throws IOException

Throws:

IOException