Uses of Interface
org.apache.flink.util.UserCodeClassLoader

Packages that use UserCodeClassLoader

Package	Description
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.serialization
org.apache.flink.api.connector.sink
org.apache.flink.api.connector.source
org.apache.flink.connector.pulsar.source.reader.deserializer
org.apache.flink.connector.testutils.source.deserialization
org.apache.flink.connector.testutils.source.reader
org.apache.flink.runtime.execution
org.apache.flink.runtime.execution.librarycache
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.chaining
org.apache.flink.runtime.operators.util
org.apache.flink.runtime.taskmanager
org.apache.flink.state.api.runtime
org.apache.flink.util

Uses of UserCodeClassLoader in org.apache.flink.api.common.functions.util

Constructors in org.apache.flink.api.common.functions.util with parameters of type UserCodeClassLoader

Constructor and Description
AbstractRuntimeUDFContext(TaskInfo taskInfo, UserCodeClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Accumulator<?,?>> accumulators, Map<String,Future<Path>> cpTasks, OperatorMetricGroup metrics)

Uses of UserCodeClassLoader in org.apache.flink.api.common.serialization

Methods in org.apache.flink.api.common.serialization that return UserCodeClassLoader

Modifier and Type	Method and Description
UserCodeClassLoader	SerializationSchema.InitializationContext.getUserCodeClassLoader() Gets the UserCodeClassLoader to load classes that are not in system's classpath, but are part of the jar file of a user job.
UserCodeClassLoader	DeserializationSchema.InitializationContext.getUserCodeClassLoader() Gets the UserCodeClassLoader to load classes that are not in system's classpath, but are part of the jar file of a user job.

Uses of UserCodeClassLoader in org.apache.flink.api.connector.sink

Methods in org.apache.flink.api.connector.sink that return UserCodeClassLoader

Modifier and Type	Method and Description
UserCodeClassLoader	Sink.InitContext.getUserCodeClassLoader() Gets the UserCodeClassLoader to load classes that are not in system's classpath, but are part of the jar file of a user job.
UserCodeClassLoader	InitContextInitializationContextAdapter.getUserCodeClassLoader()

Constructors in org.apache.flink.api.connector.sink with parameters of type UserCodeClassLoader

Constructor and Description
InitContextInitializationContextAdapter(UserCodeClassLoader userCodeClassLoader, java.util.function.Supplier<MetricGroup> metricGroupSupplier)

Uses of UserCodeClassLoader in org.apache.flink.api.connector.source

Methods in org.apache.flink.api.connector.source that return UserCodeClassLoader

Modifier and Type	Method and Description
UserCodeClassLoader	SourceReaderContext.getUserCodeClassLoader() Gets the UserCodeClassLoader to load classes that are not in system's classpath, but are part of the jar file of a user job.

Uses of UserCodeClassLoader in org.apache.flink.connector.pulsar.source.reader.deserializer

Methods in org.apache.flink.connector.pulsar.source.reader.deserializer that return UserCodeClassLoader

Modifier and Type	Method and Description
UserCodeClassLoader	PulsarDeserializationSchemaInitializationContext.getUserCodeClassLoader()

Uses of UserCodeClassLoader in org.apache.flink.connector.testutils.source.deserialization

Methods in org.apache.flink.connector.testutils.source.deserialization that return UserCodeClassLoader

Modifier and Type	Method and Description
UserCodeClassLoader	TestingDeserializationContext.getUserCodeClassLoader()

Uses of UserCodeClassLoader in org.apache.flink.connector.testutils.source.reader

Methods in org.apache.flink.connector.testutils.source.reader that return UserCodeClassLoader

Modifier and Type	Method and Description
UserCodeClassLoader	TestingReaderContext.getUserCodeClassLoader()

Uses of UserCodeClassLoader in org.apache.flink.runtime.execution

Methods in org.apache.flink.runtime.execution that return UserCodeClassLoader

Modifier and Type	Method and Description
UserCodeClassLoader	Environment.getUserCodeClassLoader() Returns the user code class loader

Uses of UserCodeClassLoader in org.apache.flink.runtime.execution.librarycache

Methods in org.apache.flink.runtime.execution.librarycache that return UserCodeClassLoader

Modifier and Type	Method and Description
UserCodeClassLoader	LibraryCacheManager.ClassLoaderHandle.getOrResolveClassLoader(Collection<PermanentBlobKey> requiredJarFiles, Collection<URL> requiredClasspaths) Gets or resolves the user code class loader for the associated job.

Uses of UserCodeClassLoader in org.apache.flink.runtime.operators

Methods in org.apache.flink.runtime.operators with parameters of type UserCodeClassLoader

Modifier and Type	Method and Description
static <T> Collector<T>	BatchTask.initOutputs(AbstractInvokable containingTask, UserCodeClassLoader cl, TaskConfig config, List<ChainedDriver<?,?>> chainedTasksTarget, List<RecordWriter<?>> eventualOutputs, ExecutionConfig executionConfig, Map<String,Accumulator<?,?>> accumulatorMap) Creates a writer for each output.

Uses of UserCodeClassLoader in org.apache.flink.runtime.operators.chaining

Methods in org.apache.flink.runtime.operators.chaining with parameters of type UserCodeClassLoader

Modifier and Type	Method and Description
void	ChainedDriver.setup(TaskConfig config, String taskName, Collector<OT> outputCollector, AbstractInvokable parent, UserCodeClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Accumulator<?,?>> accumulatorMap)

Uses of UserCodeClassLoader in org.apache.flink.runtime.operators.util

Constructors in org.apache.flink.runtime.operators.util with parameters of type UserCodeClassLoader

Constructor and Description
DistributedRuntimeUDFContext(TaskInfo taskInfo, UserCodeClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Future<Path>> cpTasks, Map<String,Accumulator<?,?>> accumulators, OperatorMetricGroup metrics, ExternalResourceInfoProvider externalResourceInfoProvider, JobID jobID)

Uses of UserCodeClassLoader in org.apache.flink.runtime.taskmanager

Methods in org.apache.flink.runtime.taskmanager that return UserCodeClassLoader

Modifier and Type	Method and Description
UserCodeClassLoader	RuntimeEnvironment.getUserCodeClassLoader()

Constructors in org.apache.flink.runtime.taskmanager with parameters of type UserCodeClassLoader

Constructor and Description

RuntimeEnvironment(JobID jobId, JobVertexID jobVertexId, ExecutionAttemptID executionId, ExecutionConfig executionConfig, TaskInfo taskInfo, Configuration jobConfiguration, Configuration taskConfiguration, UserCodeClassLoader userCodeClassLoader, MemoryManager memManager, IOManager ioManager, BroadcastVariableManager bcVarManager, TaskStateManager taskStateManager, GlobalAggregateManager aggregateManager, AccumulatorRegistry accumulatorRegistry, TaskKvStateRegistry kvStateRegistry, InputSplitProvider splitProvider, Map<String,Future<Path>> distCacheEntries, ResultPartitionWriter[] writers, IndexedInputGate[] inputGates, TaskEventDispatcher taskEventDispatcher, CheckpointResponder checkpointResponder, TaskOperatorEventGateway operatorEventGateway, TaskManagerRuntimeInfo taskManagerInfo, TaskMetricGroup metrics, Task containingTask, ExternalResourceInfoProvider externalResourceInfoProvider, ThroughputCalculator throughputCalculator)

Uses of UserCodeClassLoader in org.apache.flink.state.api.runtime

Methods in org.apache.flink.state.api.runtime that return UserCodeClassLoader

Modifier and Type	Method and Description
UserCodeClassLoader	SavepointEnvironment.getUserCodeClassLoader()

Uses of UserCodeClassLoader in org.apache.flink.util

Classes in org.apache.flink.util that implement UserCodeClassLoader

Modifier and Type	Class and Description
class	SimpleUserCodeClassLoader Simple UserCodeClassLoader implementation which assumes that the provided class loader will never be released and, hence, will never execute the release hooks.