Uses of Class
org.apache.flink.cdc.composer.definition.PipelineDef

Packages that use PipelineDef

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

Uses of PipelineDef in org.apache.flink.cdc.cli.parser

Methods in org.apache.flink.cdc.cli.parser that return PipelineDef

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

Uses of PipelineDef in org.apache.flink.cdc.composer

Methods in org.apache.flink.cdc.composer with parameters of type PipelineDef

Modifier and Type	Method	Description
PipelineExecution	PipelineComposer.compose(PipelineDef pipelineDef)	Composing pipeline execution from the specified pipeline definition.

Uses of PipelineDef in org.apache.flink.cdc.composer.flink

Methods in org.apache.flink.cdc.composer.flink with parameters of type PipelineDef

Modifier and Type	Method	Description
PipelineExecution	FlinkPipelineComposer.compose(PipelineDef pipelineDef)