Package | Description |
---|---|
org.apache.flink.client | |
org.apache.flink.client.cli | |
org.apache.flink.client.program |
Modifier and Type | Method and Description |
---|---|
static void |
ClientUtils.executeProgram(PipelineExecutorServiceLoader executorServiceLoader,
Configuration configuration,
PackagedProgram program,
boolean enforceSingleJobExecution,
boolean suppressSysout) |
Modifier and Type | Method and Description |
---|---|
protected void |
CliFrontend.executeProgram(Configuration configuration,
PackagedProgram program) |
Modifier and Type | Method and Description |
---|---|
PackagedProgram |
PackagedProgram.Builder.build() |
static JobGraph |
PackagedProgramUtils.createJobGraph(PackagedProgram packagedProgram,
Configuration configuration,
int defaultParallelism,
boolean suppressOutput)
|
static JobGraph |
PackagedProgramUtils.createJobGraph(PackagedProgram packagedProgram,
Configuration configuration,
int defaultParallelism,
JobID jobID,
boolean suppressOutput)
|
static List<File> |
PackagedProgram.extractContainedLibraries(URL jarFile)
Takes all JAR files that are contained in this program's JAR file and extracts them to the
system's temp directory.
|
String |
PackagedProgram.getDescription()
Returns the description provided by the Program class.
|
static List<URL> |
PackagedProgram.getJobJarAndDependencies(File jarFile,
String entryPointClassName)
Returns all provided libraries needed to run the program.
|
static Pipeline |
PackagedProgramUtils.getPipelineFromProgram(PackagedProgram program,
Configuration configuration,
int parallelism,
boolean suppressOutput) |
void |
PackagedProgram.invokeInteractiveModeForExecution()
This method assumes that the context environment is prepared, or the execution will be a
local execution by default.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.