Definition

Data Sink is used to apply schema changes and write change data to external systems.
A Data Sink can write to multiple tables simultaneously.

Parameters

To describe a data sink, the follows are required:

parameter	meaning	optional/required
type	The type of the sink, such as doris or starrocks.	required
name	The name of the sink, which is user-defined (a default value provided).	optional
configurations of Data Sink	Configurations to build the Data Sink e.g. connection configurations and sink table properties.	optional

Example

We could use this yaml file to define a doris sink:

sink:
    type: doris
    name: doris-sink           	# Optional parameter for description purpose
    fenodes: 127.0.0.1:8030
    username: root
    password: ""
    table.create.properties.replication_num: 1      	# Optional parameter for advanced functionalities