org.apache.flink.client.deployment.application

类 DetachedApplicationRunner

java.lang.Object

org.apache.flink.client.deployment.application.DetachedApplicationRunner

所有已实现的接口:

ApplicationRunner

@Internal
public class DetachedApplicationRunner
extends Object
implements ApplicationRunner

An ApplicationRunner which runs the user specified application using the EmbeddedExecutor. This runner invokes methods of the provided DispatcherGateway directly, 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 operations like [collect, print, printToErr, count] will fail.

构造器概要

构造器

构造器和说明
DetachedApplicationRunner(boolean enforceSingleJobExecution)

方法概要

限定符和类型	方法和说明
List<org.apache.flink.api.common.JobID>	run(org.apache.flink.runtime.dispatcher.DispatcherGateway dispatcherGateway, PackagedProgram program, org.apache.flink.configuration.Configuration configuration) Runs the application using the provided dispatcherGateway.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

DetachedApplicationRunner

public DetachedApplicationRunner(boolean enforceSingleJobExecution)

方法详细资料

run

public List<org.apache.flink.api.common.JobID> run(org.apache.flink.runtime.dispatcher.DispatcherGateway dispatcherGateway,
                                                   PackagedProgram program,
                                                   org.apache.flink.configuration.Configuration configuration)

从接口复制的说明: ApplicationRunner

Runs the application using the provided dispatcherGateway.

指定者:

run 在接口中 ApplicationRunner

参数:

dispatcherGateway - the dispatcher of the cluster to run the application.

program - the PackagedProgram containing the user's main method.

configuration - the configuration used to run the application.

返回:

a list of the submitted jobs that belong to the provided application.