Interface Factory
-
- All Known Subinterfaces:
AiModelClientFactory,DataSinkFactory,DataSourceFactory
- All Known Implementing Classes:
DorisDataSinkFactory,DummyModelClientFactory,ElasticsearchDataSinkFactory,FlussDataSinkFactory,FlussDataSourceFactory,HudiDataSinkFactory,IcebergDataSinkFactory,KafkaDataSinkFactory,MaxComputeDataSinkFactory,MySqlDataSourceFactory,OceanBaseDataSinkFactory,OpenAiCompatibleModelClientFactory,OracleDataSourceFactory,PaimonDataSinkFactory,PostgresDataSourceFactory,SqlServerDataSourceFactory,StarRocksDataSinkFactory,ValuesDataFactory
@PublicEvolving public interface Factory
Base interface for all kind of factories that create object instances from a list of key-value pairs in Flink CDC DataSource & DataSink API.A factory is uniquely identified by
Classandidentifier().The list of available factories is discovered using Java's Service Provider Interfaces (SPI). Classes that implement this interface can be added to
META_INF/services/Factoryin JAR files.Every factory declares a set of required and optional options. This information will not be used during discovery but is helpful when generating documentation and performing validation. A factory may discover further (nested) factories, the options of the nested factories must not be declared in the sets of this factory.
It is the responsibility of each factory to perform validation before returning an instance.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interfaceFactory.ContextProvides session information describing the factory to be accessed.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Stringidentifier()Returns a unique identifier among same factory interfaces.Set<ConfigOption<?>>optionalOptions()Returns a set ofConfigOptionthat an implementation of this factory consumes in addition torequiredOptions().Set<ConfigOption<?>>requiredOptions()Returns a set ofConfigOptionthat an implementation of this factory requires in addition tooptionalOptions().
-
-
-
Method Detail
-
identifier
String identifier()
Returns a unique identifier among same factory interfaces.
-
requiredOptions
Set<ConfigOption<?>> requiredOptions()
Returns a set ofConfigOptionthat an implementation of this factory requires in addition tooptionalOptions().
-
optionalOptions
Set<ConfigOption<?>> optionalOptions()
Returns a set ofConfigOptionthat an implementation of this factory consumes in addition torequiredOptions().
-
-