public class PackagedProgramUtils extends Object
PackagedProgram
related operations.Modifier and Type | Method and Description |
---|---|
static JobGraph |
createJobGraph(PackagedProgram packagedProgram,
Configuration configuration,
int defaultParallelism)
|
static JobGraph |
createJobGraph(PackagedProgram packagedProgram,
Configuration configuration,
int defaultParallelism,
JobID jobID)
|
public static JobGraph createJobGraph(PackagedProgram packagedProgram, Configuration configuration, int defaultParallelism, @Nullable JobID jobID) throws ProgramInvocationException
packagedProgram
- to extract the JobGraph fromconfiguration
- to use for the optimizer and job graph generatordefaultParallelism
- for the JobGraphjobID
- the pre-generated job idProgramInvocationException
- if the JobGraph generation failedpublic static JobGraph createJobGraph(PackagedProgram packagedProgram, Configuration configuration, int defaultParallelism) throws ProgramInvocationException
packagedProgram
- to extract the JobGraph fromconfiguration
- to use for the optimizer and job graph generatordefaultParallelism
- for the JobGraphProgramInvocationException
- if the JobGraph generation failedCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.