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 |
---|---|
static void |
ProgramOptionsUtils.configurePythonExecution(Configuration configuration,
PackagedProgram packagedProgram) |
protected void |
CliFrontend.executeProgram(Configuration configuration,
PackagedProgram program) |
Modifier and Type | Method and Description |
---|---|
PackagedProgram |
ClassPathPackagedProgramRetriever.getPackagedProgram() |
Modifier and Type | Method and Description |
---|---|
protected static void |
ApplicationClusterEntryPoint.configureExecution(Configuration configuration,
PackagedProgram program) |
static ApplicationDispatcherLeaderProcessFactoryFactory |
ApplicationDispatcherLeaderProcessFactoryFactory.create(Configuration configuration,
DispatcherFactory dispatcherFactory,
PackagedProgram program) |
List<JobID> |
DetachedApplicationRunner.run(DispatcherGateway dispatcherGateway,
PackagedProgram program,
Configuration configuration) |
List<JobID> |
ApplicationRunner.run(DispatcherGateway dispatcherGateway,
PackagedProgram program,
Configuration configuration)
Runs the application using the provided
dispatcherGateway . |
Constructor and Description |
---|
ApplicationClusterEntryPoint(Configuration configuration,
PackagedProgram program,
ResourceManagerFactory<?> resourceManagerFactory) |
ApplicationDispatcherBootstrap(PackagedProgram application,
Collection<JobID> recoveredJobIds,
Configuration configuration,
DispatcherGateway dispatcherGateway,
ScheduledExecutor scheduledExecutor,
FatalErrorHandler errorHandler) |
ApplicationDispatcherGatewayServiceFactory(Configuration configuration,
DispatcherFactory dispatcherFactory,
PackagedProgram application,
RpcService rpcService,
PartialDispatcherServices partialDispatcherServices) |
Modifier and Type | Method and Description |
---|---|
PackagedProgram |
PackagedProgram.Builder.build() |
PackagedProgram |
PackagedProgramRetriever.getPackagedProgram()
Retrieve the
PackagedProgram . |
Modifier and Type | Method and Description |
---|---|
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 Pipeline |
PackagedProgramUtils.getPipelineFromProgram(PackagedProgram program,
Configuration configuration,
int parallelism,
boolean suppressOutput) |
Modifier and Type | Method and Description |
---|---|
PackagedProgram |
JarHandlerUtils.JarHandlerContext.toPackagedProgram(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
JobGraph |
JarHandlerUtils.JarHandlerContext.toJobGraph(PackagedProgram packagedProgram,
Configuration configuration,
boolean suppressOutput) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.