@Internal public class DetachedApplicationRunner extends Object implements ApplicationRunner
ApplicationRunnerwhich runs the user specified application using the
EmbeddedExecutor. This runner invokes methods of the provided
DispatcherGatewaydirectly, and it does not go through the REST API.
In addition, this runner does not wait for the application to finish, but it submits the
application in a
DETACHED mode. As a consequence, applications with jobs that rely on
[collect, print, printToErr, count] will fail.
|Constructor and Description|
|Modifier and Type||Method and Description|
Runs the application using the provided
public DetachedApplicationRunner(boolean enforceSingleJobExecution)
public List<JobID> run(DispatcherGateway dispatcherGateway, PackagedProgram program, Configuration configuration)
dispatcherGateway- the dispatcher of the cluster to run the application.
PackagedProgramcontaining the user's main method.
configuration- the configuration used to run the application.
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.