public class PackagedProgramUtils extends Object
PackagedProgram
related operations.Modifier and Type | Method and Description |
---|---|
static JobGraph |
createJobGraph(PackagedProgram packagedProgram,
Configuration configuration,
int defaultParallelism,
boolean suppressOutput)
|
static JobGraph |
createJobGraph(PackagedProgram packagedProgram,
Configuration configuration,
int defaultParallelism,
JobID jobID,
boolean suppressOutput)
|
static Pipeline |
getPipelineFromProgram(PackagedProgram prog,
Configuration configuration,
int parallelism,
boolean suppressOutput) |
static Boolean |
isPython(String entryPointClassName) |
public static JobGraph createJobGraph(PackagedProgram packagedProgram, Configuration configuration, int defaultParallelism, @Nullable JobID jobID, boolean suppressOutput) 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, boolean suppressOutput) throws ProgramInvocationException
packagedProgram
- to extract the JobGraph fromconfiguration
- to use for the optimizer and job graph generatordefaultParallelism
- for the JobGraphsuppressOutput
- Whether to suppress stdout/stderr during interactive JobGraph creation.ProgramInvocationException
- if the JobGraph generation failedpublic static Pipeline getPipelineFromProgram(PackagedProgram prog, Configuration configuration, int parallelism, boolean suppressOutput) throws CompilerException, ProgramInvocationException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.