public class ProgramDeployer extends Object
Constructor and Description |
---|
ProgramDeployer(Configuration configuration,
String jobName,
Pipeline pipeline,
ClassLoader userCodeClassloader)
Deploys a table program on the cluster.
|
public ProgramDeployer(Configuration configuration, String jobName, Pipeline pipeline, ClassLoader userCodeClassloader)
configuration
- the Configuration
that is used for deploymentjobName
- job name of the Flink job to be submittedpipeline
- Flink Pipeline
to executepublic CompletableFuture<JobClient> deploy()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.