public class PipelineExecutorUtils extends Object
|Constructor and Description|
|Modifier and Type||Method and Description|
public static JobGraph getJobGraph(@Nonnull Pipeline pipeline, @Nonnull Configuration configuration, @Nonnull ClassLoader userClassloader) throws MalformedURLException
pipeline- the pipeline whose job graph we are computing.
configuration- the configuration with the necessary information such as jars and classpaths to be included, the parallelism of the job and potential savepoint settings used to bootstrap its state.
userClassloader- the classloader which can load user classes.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.