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

Interface PipelineDefinitionParser

All Known Implementing Classes:

YamlPipelineDefinitionParser

public interface PipelineDefinitionParser

Parsing pipeline definition files and generate PipelineDef.

Method Summary

Modifier and Type	Method	Description
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 path, merge global configurations, then generate the PipelineDef.

Method Detail

parse

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

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

Throws:

Exception

parse

PipelineDef parse(String pipelineDefText,
                  Configuration globalPipelineConfig)
           throws Exception

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

Throws:

Exception