Package org.apache.flink.cdc.cli.parser

Class YamlPipelineDefinitionParser

java.lang.Object

org.apache.flink.cdc.cli.parser.YamlPipelineDefinitionParser

All Implemented Interfaces:

PipelineDefinitionParser

public class YamlPipelineDefinitionParser
extends Object
implements PipelineDefinitionParser

Parser for converting YAML formatted pipeline definition to PipelineDef.

Field Summary

Fields

Modifier and Type	Field	Description
static String	TRANSFORM_PARTITION_KEY_KEY
static String	TRANSFORM_PRIMARY_KEY_KEY
static String	TRANSFORM_TABLE_OPTION_DELIMITER_KEY
static String	TRANSFORM_TABLE_OPTION_KEY

Constructor Summary

Constructors

Constructor	Description
YamlPipelineDefinitionParser()

Method Summary

Modifier and Type	Method	Description
static Map<String,String>	getFlinkConfigFromPipelineDef(org.apache.flink.core.fs.Path pipelineDefPath)
PipelineDef	parse(String pipelineDefText, Configuration globalPipelineConfig)	Parse the specified pipeline definition string, merge global configurations, then generate the PipelineDef.
PipelineDef	parse(org.apache.flink.core.fs.Path pipelineDefPath, Configuration globalPipelineConfig)	Parse the specified pipeline definition file.

Methods inherited from class java.lang.Object

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

Field Detail

TRANSFORM_PRIMARY_KEY_KEY

public static final String TRANSFORM_PRIMARY_KEY_KEY

See Also:

Constant Field Values

TRANSFORM_PARTITION_KEY_KEY

public static final String TRANSFORM_PARTITION_KEY_KEY

See Also:

Constant Field Values

TRANSFORM_TABLE_OPTION_KEY

public static final String TRANSFORM_TABLE_OPTION_KEY

See Also:

Constant Field Values

TRANSFORM_TABLE_OPTION_DELIMITER_KEY

public static final String TRANSFORM_TABLE_OPTION_DELIMITER_KEY

See Also:

Constant Field Values

Constructor Detail

YamlPipelineDefinitionParser

public YamlPipelineDefinitionParser()

Method Detail

parse

public PipelineDef parse(org.apache.flink.core.fs.Path pipelineDefPath,
                         Configuration globalPipelineConfig)
                  throws Exception

Parse the specified pipeline definition file.

Specified by:

parse in interface PipelineDefinitionParser

Throws:

Exception

parse

public PipelineDef parse(String pipelineDefText,
                         Configuration globalPipelineConfig)
                  throws Exception

Description copied from interface: PipelineDefinitionParser

Parse the specified pipeline definition string, merge global configurations, then generate the PipelineDef.

Specified by:

parse in interface PipelineDefinitionParser

Throws:

Exception

getFlinkConfigFromPipelineDef

public static Map<String,String> getFlinkConfigFromPipelineDef(org.apache.flink.core.fs.Path pipelineDefPath)
                                                              throws IOException

Throws:

IOException