Package org.apache.flink.cdc.cli.utils

Class FlinkEnvironmentUtils

java.lang.Object

org.apache.flink.cdc.cli.utils.FlinkEnvironmentUtils

public class FlinkEnvironmentUtils
extends Object

Utilities for handling Flink configuration and environment.

Constructor Summary

Constructors

Constructor	Description
FlinkEnvironmentUtils()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.runtime.jobgraph.SavepointRestoreSettings	createSavepointRestoreSettings(org.apache.flink.configuration.Configuration flinkConfig)
static org.apache.flink.core.fs.Path	getFlinkHome(org.apache.commons.cli.CommandLine commandLine)
static org.apache.flink.configuration.Configuration	mergeFlinkConfigurationsWithPriority(org.apache.flink.core.fs.Path pipelineDefPath, org.apache.commons.cli.CommandLine commandLine)	Load and merge Flink configurations by priority rules.

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkEnvironmentUtils

public FlinkEnvironmentUtils()

Method Detail

mergeFlinkConfigurationsWithPriority

public static org.apache.flink.configuration.Configuration mergeFlinkConfigurationsWithPriority(org.apache.flink.core.fs.Path pipelineDefPath,
                                                                                                org.apache.commons.cli.CommandLine commandLine)
                                                                                         throws Exception

Load and merge Flink configurations by priority rules.

Throws:

Exception

getFlinkHome

public static org.apache.flink.core.fs.Path getFlinkHome(org.apache.commons.cli.CommandLine commandLine)

createSavepointRestoreSettings

public static org.apache.flink.runtime.jobgraph.SavepointRestoreSettings createSavepointRestoreSettings(org.apache.flink.configuration.Configuration flinkConfig)