@Internal public final class SimpleInitializeOnMasterContext extends Object implements JobVertex.InitializeOnMasterContext
JobVertex.InitializeOnMasterContext
.Constructor and Description |
---|
SimpleInitializeOnMasterContext(ClassLoader loader,
int executionParallelism) |
Modifier and Type | Method and Description |
---|---|
ClassLoader |
getClassLoader()
The class loader for user defined code.
|
int |
getExecutionParallelism()
The actual parallelism this vertex will be run with.
|
public SimpleInitializeOnMasterContext(ClassLoader loader, int executionParallelism)
public ClassLoader getClassLoader()
JobVertex.InitializeOnMasterContext
getClassLoader
in interface JobVertex.InitializeOnMasterContext
public int getExecutionParallelism()
JobVertex.InitializeOnMasterContext
JobVertex.getParallelism()
is the original parallelism set when creating the JobGraph
and
might be updated e.g. by the AdaptiveScheduler
.getExecutionParallelism
in interface JobVertex.InitializeOnMasterContext
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.