Constructor and Description |
---|
ExecutionContext(Configuration flinkConfig,
MutableURLClassLoader classLoader,
SessionContext.SessionState sessionState) |
Constructor and Description |
---|
ClientResourceManager(Configuration config,
MutableURLClassLoader userClassLoader) |
Modifier and Type | Class and Description |
---|---|
class |
ClientWrapperClassLoader
This class loader extends
FlinkUserCodeClassLoaders.SafetyNetWrapperClassLoader , upon the addURL method, it
also exposes a removeURL method which used to remove unnecessary jar from current
classloader path. |
Modifier and Type | Field and Description |
---|---|
protected MutableURLClassLoader |
ResourceManager.userClassLoader |
Constructor and Description |
---|
ResourceManager(ReadableConfig config,
MutableURLClassLoader userClassLoader) |
Modifier and Type | Class and Description |
---|---|
class |
ChildFirstClassLoader
A variant of the URLClassLoader that first loads from the URLs and only after that from the
parent.
|
class |
FlinkUserCodeClassLoader
This class loader accepts a custom handler if an exception occurs in
FlinkUserCodeClassLoader.loadClass(String,
boolean) . |
static class |
FlinkUserCodeClassLoaders.ParentFirstClassLoader
Regular URLClassLoader that first loads from the parent and only after that from the URLs.
|
static class |
FlinkUserCodeClassLoaders.SafetyNetWrapperClassLoader
Ensures that holding a reference on the context class loader outliving the scope of user code
does not prevent the user classloader to be garbage collected (FLINK-16245).
|
Modifier and Type | Method and Description |
---|---|
static MutableURLClassLoader |
FlinkUserCodeClassLoaders.childFirst(URL[] urls,
ClassLoader parent,
String[] alwaysParentFirstPatterns,
java.util.function.Consumer<Throwable> classLoadingExceptionHandler,
boolean checkClassLoaderLeak) |
static MutableURLClassLoader |
FlinkUserCodeClassLoaders.create(FlinkUserCodeClassLoaders.ResolveOrder resolveOrder,
URL[] urls,
ClassLoader parent,
String[] alwaysParentFirstPatterns,
java.util.function.Consumer<Throwable> classLoadingExceptionHandler,
boolean checkClassLoaderLeak) |
static MutableURLClassLoader |
FlinkUserCodeClassLoaders.create(URL[] urls,
ClassLoader parent,
ReadableConfig config) |
static MutableURLClassLoader |
FlinkUserCodeClassLoaders.parentFirst(URL[] urls,
ClassLoader parent,
java.util.function.Consumer<Throwable> classLoadingExceptionHandler,
boolean checkClassLoaderLeak) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.