Package org.apache.flink.cdc.cli

Class CliExecutor

java.lang.Object

org.apache.flink.cdc.cli.CliExecutor

public class CliExecutor
extends Object

Executor for doing the composing and submitting logic for CliFrontend.

Constructor Summary

Constructors

Constructor	Description
CliExecutor(org.apache.commons.cli.CommandLine commandLine, org.apache.flink.core.fs.Path pipelineDefPath, org.apache.flink.configuration.Configuration flinkConfig, Configuration globalPipelineConfig, List<org.apache.flink.core.fs.Path> additionalJars, org.apache.flink.core.fs.Path flinkHome)

Method Summary

Modifier and Type	Method	Description
PipelineExecution.ExecutionInfo	deployWithNoOpComposer()
List<org.apache.flink.core.fs.Path>	getAdditionalJars()
String	getDeploymentTarget()
org.apache.flink.configuration.Configuration	getFlinkConfig()
Configuration	getGlobalPipelineConfig()
static void	main(String[] args)
PipelineExecution.ExecutionInfo	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

CliExecutor

public CliExecutor(org.apache.commons.cli.CommandLine commandLine,
                   org.apache.flink.core.fs.Path pipelineDefPath,
                   org.apache.flink.configuration.Configuration flinkConfig,
                   Configuration globalPipelineConfig,
                   List<org.apache.flink.core.fs.Path> additionalJars,
                   org.apache.flink.core.fs.Path flinkHome)

Method Detail

run

public PipelineExecution.ExecutionInfo run()
                                    throws Exception

Throws:

Exception

deployWithNoOpComposer

@VisibleForTesting
public PipelineExecution.ExecutionInfo deployWithNoOpComposer()
                                                       throws Exception

Throws:

Exception

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

getFlinkConfig

@VisibleForTesting
public org.apache.flink.configuration.Configuration getFlinkConfig()

getGlobalPipelineConfig

@VisibleForTesting
public Configuration getGlobalPipelineConfig()

getAdditionalJars

@VisibleForTesting
public List<org.apache.flink.core.fs.Path> getAdditionalJars()

getDeploymentTarget

public String getDeploymentTarget()