@Internal public final class ThreadLocalClassLoaderConfiguration extends Configuration
Since the conf is effectively cached across Flink jobs, at least force the thread local classloader to avoid classloader leaks.
Configuration.DeprecationDelta, Configuration.IntegerRanges
Constructor and Description |
---|
ThreadLocalClassLoaderConfiguration() |
ThreadLocalClassLoaderConfiguration(Configuration other) |
Modifier and Type | Method and Description |
---|---|
Class<?> |
getClassByNameOrNull(String name)
Load a class by name, returning null rather than throwing an exception if it couldn't be
loaded.
|
ClassLoader |
getClassLoader()
Get the
ClassLoader for this job. |
URL |
getResource(String name)
Get the
URL for the named resource. |
addDefaultResource, addDeprecation, addDeprecation, addDeprecation, addDeprecation, addDeprecations, addResource, addResource, addResource, addResource, addResource, addResource, addResource, addResource, addResource, addResource, addResource, clear, dumpConfiguration, dumpConfiguration, dumpDeprecatedKeys, get, get, getBoolean, getClass, getClass, getClassByName, getClasses, getConfResourceAsInputStream, getConfResourceAsReader, getDouble, getEnum, getFile, getFinalParameters, getFloat, getInstances, getInt, getInts, getLocalPath, getLong, getLongBytes, getPassword, getPasswordFromConfig, getPasswordFromCredentialProviders, getPattern, getPropertySources, getProps, getPropsWithPrefix, getRange, getRaw, getSocketAddr, getSocketAddr, getStorageSize, getStorageSize, getStringCollection, getStrings, getStrings, getTimeDuration, getTimeDuration, getTimeDurationHelper, getTimeDurations, getTrimmed, getTrimmed, getTrimmedStringCollection, getTrimmedStrings, getTrimmedStrings, getValByRegex, hasWarnedDeprecation, isDeprecated, iterator, main, onlyKeyExists, readFields, reloadConfiguration, reloadExistingConfigurations, set, set, setAllowNullValueProperties, setBoolean, setBooleanIfUnset, setClass, setClassLoader, setDeprecatedProperties, setDouble, setEnum, setFloat, setIfUnset, setInt, setLong, setPattern, setQuietMode, setRestrictSystemProperties, setRestrictSystemPropertiesDefault, setRestrictSystemProps, setSocketAddr, setStorageSize, setStrings, setTimeDuration, size, toString, unset, updateConnectAddr, updateConnectAddr, write, writeXml, writeXml, writeXml
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
forEach, spliterator
public ThreadLocalClassLoaderConfiguration()
public ThreadLocalClassLoaderConfiguration(Configuration other)
public ClassLoader getClassLoader()
Configuration
ClassLoader
for this job.getClassLoader
in class Configuration
public Class<?> getClassByNameOrNull(String name)
Configuration
getClassByNameOrNull
in class Configuration
name
- the class namepublic URL getResource(String name)
Configuration
URL
for the named resource.getResource
in class Configuration
name
- resource name.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.