Uses of Interface
org.apache.flink.cdc.common.sink.DataSink

Packages that use DataSink

Package	Description
org.apache.flink.cdc.common.factories
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.connectors.doris.factory
org.apache.flink.cdc.connectors.doris.sink
org.apache.flink.cdc.connectors.elasticsearch.sink
org.apache.flink.cdc.connectors.fluss.factory
org.apache.flink.cdc.connectors.fluss.sink
org.apache.flink.cdc.connectors.hudi.sink
org.apache.flink.cdc.connectors.iceberg.sink
org.apache.flink.cdc.connectors.kafka.sink
org.apache.flink.cdc.connectors.maxcompute
org.apache.flink.cdc.connectors.oceanbase.factory
org.apache.flink.cdc.connectors.oceanbase.sink
org.apache.flink.cdc.connectors.paimon.sink
org.apache.flink.cdc.connectors.starrocks.sink
org.apache.flink.cdc.connectors.values.factory
org.apache.flink.cdc.connectors.values.sink

Uses of DataSink in org.apache.flink.cdc.common.factories

Methods in org.apache.flink.cdc.common.factories that return DataSink

Modifier and Type	Method	Description
DataSink	DataSinkFactory.createDataSink(Factory.Context context)	Creates a DataSink instance.

Uses of DataSink in org.apache.flink.cdc.composer.flink.translator

Methods in org.apache.flink.cdc.composer.flink.translator that return DataSink

Modifier and Type	Method	Description
DataSink	DataSinkTranslator.createDataSink(SinkDef sinkDef, Configuration pipelineConfig, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)

Methods in org.apache.flink.cdc.composer.flink.translator with parameters of type DataSink

Modifier and Type	Method	Description
void	DataSinkTranslator.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)
void	DataSinkTranslator.translate(SinkDef sinkDef, org.apache.flink.streaming.api.datastream.DataStream<Event> input, DataSink dataSink, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID, OperatorUidGenerator operatorUidGenerator)

Uses of DataSink in org.apache.flink.cdc.connectors.doris.factory

Methods in org.apache.flink.cdc.connectors.doris.factory that return DataSink

Modifier and Type	Method	Description
DataSink	DorisDataSinkFactory.createDataSink(Factory.Context context)

Uses of DataSink in org.apache.flink.cdc.connectors.doris.sink

Classes in org.apache.flink.cdc.connectors.doris.sink that implement DataSink

Modifier and Type	Class	Description
class	DorisDataSink	A DataSink for "Doris" connector.

Uses of DataSink in org.apache.flink.cdc.connectors.elasticsearch.sink

Classes in org.apache.flink.cdc.connectors.elasticsearch.sink that implement DataSink

Modifier and Type	Class	Description
class	ElasticsearchDataSink<InputT>	An implementation of DataSink for writing events to Elasticsearch.

Methods in org.apache.flink.cdc.connectors.elasticsearch.sink that return DataSink

Modifier and Type	Method	Description
DataSink	ElasticsearchDataSinkFactory.createDataSink(Factory.Context context)

Uses of DataSink in org.apache.flink.cdc.connectors.fluss.factory

Methods in org.apache.flink.cdc.connectors.fluss.factory that return DataSink

Modifier and Type	Method	Description
DataSink	FlussDataSinkFactory.createDataSink(Factory.Context context)

Uses of DataSink in org.apache.flink.cdc.connectors.fluss.sink

Classes in org.apache.flink.cdc.connectors.fluss.sink that implement DataSink

Modifier and Type	Class	Description
class	FlussDataSink	A DataSink implementation for Fluss.

Uses of DataSink in org.apache.flink.cdc.connectors.hudi.sink

Classes in org.apache.flink.cdc.connectors.hudi.sink that implement DataSink

Modifier and Type	Class	Description
class	HudiDataSink	A DataSink for Apache Hudi that provides the main entry point for the Flink CDC framework.

Uses of DataSink in org.apache.flink.cdc.connectors.iceberg.sink

Classes in org.apache.flink.cdc.connectors.iceberg.sink that implement DataSink

Modifier and Type	Class	Description
class	IcebergDataSink	A DataSink for Apache Iceberg.

Methods in org.apache.flink.cdc.connectors.iceberg.sink that return DataSink

Modifier and Type	Method	Description
DataSink	IcebergDataSinkFactory.createDataSink(Factory.Context context)

Uses of DataSink in org.apache.flink.cdc.connectors.kafka.sink

Classes in org.apache.flink.cdc.connectors.kafka.sink that implement DataSink

Modifier and Type	Class	Description
class	KafkaDataSink	A DataSink for "Kafka" connector.

Methods in org.apache.flink.cdc.connectors.kafka.sink that return DataSink

Modifier and Type	Method	Description
DataSink	KafkaDataSinkFactory.createDataSink(Factory.Context context)

Uses of DataSink in org.apache.flink.cdc.connectors.maxcompute

Classes in org.apache.flink.cdc.connectors.maxcompute that implement DataSink

Modifier and Type	Class	Description
class	MaxComputeDataSink	A DataSink for "MaxCompute" connector.

Methods in org.apache.flink.cdc.connectors.maxcompute that return DataSink

Modifier and Type	Method	Description
DataSink	MaxComputeDataSinkFactory.createDataSink(Factory.Context context)

Uses of DataSink in org.apache.flink.cdc.connectors.oceanbase.factory

Methods in org.apache.flink.cdc.connectors.oceanbase.factory that return DataSink

Modifier and Type	Method	Description
DataSink	OceanBaseDataSinkFactory.createDataSink(Factory.Context context)

Uses of DataSink in org.apache.flink.cdc.connectors.oceanbase.sink

Classes in org.apache.flink.cdc.connectors.oceanbase.sink that implement DataSink

Modifier and Type	Class	Description
class	OceanBaseDataSink	A DataSink for "OceanBase" pipeline connector.

Uses of DataSink in org.apache.flink.cdc.connectors.paimon.sink

Classes in org.apache.flink.cdc.connectors.paimon.sink that implement DataSink

Modifier and Type	Class	Description
class	PaimonDataSink	A DataSink for Paimon connector that supports schema evolution.

Methods in org.apache.flink.cdc.connectors.paimon.sink that return DataSink

Modifier and Type	Method	Description
DataSink	PaimonDataSinkFactory.createDataSink(Factory.Context context)

Uses of DataSink in org.apache.flink.cdc.connectors.starrocks.sink

Classes in org.apache.flink.cdc.connectors.starrocks.sink that implement DataSink

Modifier and Type	Class	Description
class	StarRocksDataSink	A DataSink for StarRocks connector that supports schema evolution.

Methods in org.apache.flink.cdc.connectors.starrocks.sink that return DataSink

Modifier and Type	Method	Description
DataSink	StarRocksDataSinkFactory.createDataSink(Factory.Context context)

Uses of DataSink in org.apache.flink.cdc.connectors.values.factory

Methods in org.apache.flink.cdc.connectors.values.factory that return DataSink

Modifier and Type	Method	Description
DataSink	ValuesDataFactory.createDataSink(Factory.Context context)

Uses of DataSink in org.apache.flink.cdc.connectors.values.sink

Classes in org.apache.flink.cdc.connectors.values.sink that implement DataSink

Modifier and Type	Class	Description
class	ValuesDataSink	A DataSink for "values" connector that supports schema evolution.