@Internal public class ApplicationDispatcherBootstrap extends Object implements DispatcherBootstrap
DispatcherBootstrapused for running the user's
main()in "Application Mode" (see FLIP-85).
This dispatcher bootstrap submits the recovered
job graphs for re-execution
(in case of recovery from a failure), and then submits the remaining jobs of the application for
To achieve this, it works in conjunction with the
which decides if it should submit a job for execution (in case of a new job) or the job was
already recovered and is running.
|Modifier and Type||Field and Description|
|Constructor and Description|
public static final JobID ZERO_JOB_ID
public ApplicationDispatcherBootstrap(PackagedProgram application, Collection<JobID> recoveredJobIds, Configuration configuration, DispatcherGateway dispatcherGateway, ScheduledExecutor scheduledExecutor, FatalErrorHandler errorHandler)
public void stop()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.