Package org.apache.flink.cdc.composer

Interface PipelineDeploymentExecutor

All Known Implementing Classes:

K8SApplicationDeploymentExecutor, YarnApplicationDeploymentExecutor

public interface PipelineDeploymentExecutor

PipelineDeploymentExecutor to execute flink cdc job from different target.

Method Summary

Modifier and Type	Method	Description
PipelineExecution.ExecutionInfo	deploy(org.apache.commons.cli.CommandLine commandLine, org.apache.flink.configuration.Configuration flinkConfig, List<org.apache.flink.core.fs.Path> additionalJars, org.apache.flink.core.fs.Path flinkHome)

Method Detail

deploy

PipelineExecution.ExecutionInfo deploy(org.apache.commons.cli.CommandLine commandLine,
                                       org.apache.flink.configuration.Configuration flinkConfig,
                                       List<org.apache.flink.core.fs.Path> additionalJars,
                                       org.apache.flink.core.fs.Path flinkHome)
                                throws Exception

Throws:

Exception