Package org.apache.flink.cdc.composer
Interface PipelineComposer
-
- All Known Implementing Classes:
FlinkPipelineComposer
public interface PipelineComposerComposer for translating a pipeline definition to an execution.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description PipelineExecutioncompose(PipelineDef pipelineDef)Composing pipeline execution from the specified pipeline definition.
-
-
-
Method Detail
-
compose
PipelineExecution compose(PipelineDef pipelineDef)
Composing pipeline execution from the specified pipeline definition.- Parameters:
pipelineDef- definition of the pipeline
-
-