org.apache.flink.table.client.gateway.local

Class ProgramDeployer

java.lang.Object

org.apache.flink.table.client.gateway.local.ProgramDeployer

public class ProgramDeployer
extends Object

The helper class to deploy a table program on the cluster.

Constructor Summary

Constructors

Constructor and Description
ProgramDeployer(Configuration configuration, String jobName, Pipeline pipeline) Deploys a table program on the cluster.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<JobClient>	deploy()

Methods inherited from class java.lang.Object

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

Constructor Detail

ProgramDeployer

public ProgramDeployer(Configuration configuration,
                       String jobName,
                       Pipeline pipeline)

Deploys a table program on the cluster.

Parameters:

configuration - the Configuration that is used for deployment

jobName - job name of the Flink job to be submitted

pipeline - Flink Pipeline to execute

Method Detail

deploy

public CompletableFuture<JobClient> deploy()