org.apache.flink.client.cli

接口 ApplicationDeployer

所有已知实现类:

ApplicationClusterDeployer

@Internal
public interface ApplicationDeployer

An interface to be used by the CliFrontend to submit user programs for execution.

方法概要

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

方法详细资料

run

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

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

参数:

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

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

抛出:

Exception