org.apache.flink.client.deployment.application.cli

类 ApplicationClusterDeployer

java.lang.Object

org.apache.flink.client.deployment.application.cli.ApplicationClusterDeployer

所有已实现的接口:

ApplicationDeployer

@Internal
public class ApplicationClusterDeployer
extends Object
implements ApplicationDeployer

An entity responsible for submitting an application for execution in "Application Mode", i.e. on a dedicated cluster that is created on application submission and torn down upon application termination, and with its main() executed on the cluster, rather than the client.

构造器概要

构造器

构造器和说明
ApplicationClusterDeployer(ClusterClientServiceLoader clientServiceLoader)

方法概要

限定符和类型	方法和说明
<ClusterID> void	run(org.apache.flink.configuration.Configuration configuration, ApplicationConfiguration applicationConfiguration) Submits a user program for execution and runs the main user method on the cluster.

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

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

构造器详细资料

ApplicationClusterDeployer

public ApplicationClusterDeployer(ClusterClientServiceLoader clientServiceLoader)

方法详细资料

run

public <ClusterID> void run(org.apache.flink.configuration.Configuration configuration,
                            ApplicationConfiguration applicationConfiguration)
                     throws Exception

从接口复制的说明: ApplicationDeployer

Submits a user program for execution and runs the main user method on the cluster.

指定者:

run 在接口中 ApplicationDeployer

参数:

configuration - the configuration containing all the necessary information about submitting the user program.

applicationConfiguration - an ApplicationConfiguration specific to the application to be executed.

抛出:

Exception