Uses of Class
org.apache.flink.cdc.composer.definition.SinkDef
-
Packages that use SinkDef Package Description org.apache.flink.cdc.composer.definition org.apache.flink.cdc.composer.flink.translator -
-
Uses of SinkDef in org.apache.flink.cdc.composer.definition
Methods in org.apache.flink.cdc.composer.definition that return SinkDef Modifier and Type Method Description SinkDefPipelineDef. getSink()Constructors in org.apache.flink.cdc.composer.definition with parameters of type SinkDef 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 SinkDef in org.apache.flink.cdc.composer.flink.translator
Methods in org.apache.flink.cdc.composer.flink.translator with parameters of type SinkDef Modifier and Type Method Description DataSinkDataSinkTranslator. createDataSink(SinkDef sinkDef, Configuration pipelineConfig, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)voidDataSinkTranslator. translate(SinkDef sinkDef, org.apache.flink.streaming.api.datastream.DataStream<Event> input, DataSink dataSink, boolean isBatchMode, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID, OperatorUidGenerator operatorUidGenerator)voidDataSinkTranslator. translate(SinkDef sinkDef, org.apache.flink.streaming.api.datastream.DataStream<Event> input, DataSink dataSink, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID, OperatorUidGenerator operatorUidGenerator)
-