Uses of Interface
org.apache.flink.cdc.composer.PipelineExecution

Packages that use PipelineExecution

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

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

Methods in org.apache.flink.cdc.composer that return PipelineExecution

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

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

Classes in org.apache.flink.cdc.composer.flink that implement PipelineExecution

Modifier and Type	Class	Description
class	FlinkPipelineExecution	A pipeline execution that run the defined pipeline via Flink's StreamExecutionEnvironment.

Methods in org.apache.flink.cdc.composer.flink that return PipelineExecution

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