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

Class ApplicationClusterDeployer

java.lang.Object

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

All Implemented Interfaces:

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.

Constructor Summary

Constructors

Constructor and Description
ApplicationClusterDeployer(ClusterClientServiceLoader clientServiceLoader)

Method Summary

Modifier and Type	Method and Description
<ClusterID> void	run(Configuration configuration, ApplicationConfiguration applicationConfiguration) Submits a user program for execution and runs the main user method on the cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

ApplicationClusterDeployer

public ApplicationClusterDeployer(ClusterClientServiceLoader clientServiceLoader)

Method Detail

run

public <ClusterID> void run(Configuration configuration,
                            ApplicationConfiguration applicationConfiguration)
                     throws Exception

Description copied from interface: ApplicationDeployer

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

Specified by:

run in interface ApplicationDeployer

Parameters:

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

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

Throws:

Exception