Package org.apache.flink.cdc.common.factories

Interface DataSinkFactory

All Superinterfaces:

Factory

All Known Implementing Classes:

DorisDataSinkFactory, ElasticsearchDataSinkFactory, FlussDataSinkFactory, HudiDataSinkFactory, IcebergDataSinkFactory, KafkaDataSinkFactory, MaxComputeDataSinkFactory, OceanBaseDataSinkFactory, PaimonDataSinkFactory, StarRocksDataSinkFactory, ValuesDataFactory

@PublicEvolving
public interface DataSinkFactory
extends Factory

A factory to create DataSink instances. See also Factory for more information.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.cdc.common.factories.Factory

Factory.Context

Method Summary

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

Methods inherited from interface org.apache.flink.cdc.common.factories.Factory

identifier, optionalOptions, requiredOptions

Method Detail

createDataSink

DataSink createDataSink(Factory.Context context)

Creates a DataSink instance.