Package org.apache.flink.cdc.composer
Interface PipelineExecution
-
- All Known Implementing Classes:
FlinkPipelineExecution
public interface PipelineExecutionA pipeline execution that can be executed by a computing engine.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static classPipelineExecution.ExecutionInfoInformation of the execution.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description PipelineExecution.ExecutionInfoexecute()Execute the pipeline.
-
-
-
Method Detail
-
execute
PipelineExecution.ExecutionInfo execute() throws Exception
Execute the pipeline.- Throws:
Exception
-
-