Package org.apache.flink.table.client.resource

Class ClientResourceManager

java.lang.Object

org.apache.flink.table.resource.ResourceManager

org.apache.flink.table.client.resource.ClientResourceManager

All Implemented Interfaces:

Closeable, AutoCloseable

@Internal
public class ClientResourceManager
extends org.apache.flink.table.resource.ResourceManager

The ClientResourceManager is able to remove the registered JAR resources with the specified jar path.

After removing the JAR resource, the ResourceManager is able to register the JAR resource with the same JAR path. Please notice that the removal doesn't promise the loaded Class from the removed jar is inaccessible.

Field Summary

Fields inherited from class org.apache.flink.table.resource.ResourceManager

resourceInfos, userClassLoader

Constructor Summary

Constructors

Constructor	Description
ClientResourceManager(org.apache.flink.configuration.Configuration config, org.apache.flink.util.MutableURLClassLoader userClassLoader)

Method Summary

Modifier and Type	Method	Description
URL	unregisterJarResource(String jarPath)

Methods inherited from class org.apache.flink.table.resource.ResourceManager

addJarConfiguration, checkPath, close, createResourceManager, exists, getLocalJarResources, getResources, getURLFromPath, getUserClassLoader, registerFileResource, registerJarResources, syncFileResource

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientResourceManager

public ClientResourceManager(org.apache.flink.configuration.Configuration config,
                             org.apache.flink.util.MutableURLClassLoader userClassLoader)

Method Detail

unregisterJarResource

@Nullable
public URL unregisterJarResource(String jarPath)