org.apache.flink.client.deployment.application

接口 ApplicationRunner

所有已知实现类:

DetachedApplicationRunner

@Internal
public interface ApplicationRunner

An interface to be implemented by the entities responsible for application submission for the different deployment environments.

This interface assumes access to the cluster's DispatcherGateway, and it does not go through the publicly exposed REST API.

方法概要

限定符和类型	方法和说明
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.

方法详细资料

run

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.

参数:

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.