Uses of Class
org.apache.flink.cdc.composer.definition.SourceDef
-
Packages that use SourceDef Package Description org.apache.flink.cdc.composer.definition org.apache.flink.cdc.composer.flink.translator -
-
Uses of SourceDef in org.apache.flink.cdc.composer.definition
Methods in org.apache.flink.cdc.composer.definition that return SourceDef Modifier and Type Method Description SourceDefPipelineDef. getSource()Constructors in org.apache.flink.cdc.composer.definition with parameters of type SourceDef Constructor Description PipelineDef(SourceDef source, SinkDef sink, List<RouteDef> routes, List<TransformDef> transforms, List<UdfDef> udfs, List<ModelDef> models, Configuration config)PipelineDef(SourceDef source, SinkDef sink, List<RouteDef> routes, List<TransformDef> transforms, List<UdfDef> udfs, Configuration config) -
Uses of SourceDef in org.apache.flink.cdc.composer.flink.translator
Methods in org.apache.flink.cdc.composer.flink.translator with parameters of type SourceDef Modifier and Type Method Description DataSourceDataSourceTranslator. createDataSource(SourceDef sourceDef, Configuration pipelineConfig, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)org.apache.flink.streaming.api.datastream.DataStream<Event>DataSourceTranslator. translate(SourceDef sourceDef, DataSource dataSource, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, int sourceParallelism, OperatorUidGenerator operatorUidGenerator)
-