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 and Description
CliExecutor(org.apache.commons.cli.CommandLine commandLine, Path pipelineDefPath, Configuration flinkConfig, Configuration globalPipelineConfig, boolean useMiniCluster, List<Path> additionalJars, org.apache.flink.runtime.jobgraph.SavepointRestoreSettings savepointSettings)

Method Summary

Modifier and Type	Method and Description
List<Path>	getAdditionalJars()
String	getDeploymentTarget()
Configuration	getFlinkConfig()
Configuration	getGlobalPipelineConfig()
org.apache.flink.runtime.jobgraph.SavepointRestoreSettings	getSavepointSettings()
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,
                   Path pipelineDefPath,
                   Configuration flinkConfig,
                   Configuration globalPipelineConfig,
                   boolean useMiniCluster,
                   List<Path> additionalJars,
                   org.apache.flink.runtime.jobgraph.SavepointRestoreSettings savepointSettings)

Method Detail

run

public PipelineExecution.ExecutionInfo run()
                                    throws Exception

Throws:

Exception

getFlinkConfig

@VisibleForTesting
public Configuration getFlinkConfig()

getGlobalPipelineConfig

@VisibleForTesting
public Configuration getGlobalPipelineConfig()

getAdditionalJars

@VisibleForTesting
public List<Path> getAdditionalJars()

getDeploymentTarget

@VisibleForTesting
public String getDeploymentTarget()

getSavepointSettings

public org.apache.flink.runtime.jobgraph.SavepointRestoreSettings getSavepointSettings()