public class PipelineExecutorUtils extends Object
|Constructor and Description|
|Modifier and Type||Method and Description|
public static JobGraph getJobGraph(@Nonnull Pipeline pipeline, @Nonnull Configuration configuration) 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.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.