manshu

Customize the sink class, extends richsinkfunction and implement checkpointedfunction. In invoke dynamically sink through the properties in the custom entity object. The properties of the custom entity object are databasename,...

Yes, encapsulate such a data structure, dynamically load by spelling the URL on the sink side, and add a keyby operator before sink ------------------ 原始邮件 ------------------ 发件人: "apache/doris" ***@***.***>; 发送时间: 2022年7月28日(星期四) 中午11:48 ***@***.***>;...

What you said is quite right. My idea is like this. The previous answer may not be described clearly ------------------ 原始邮件 ------------------ 发件人: "apache/doris" ***@***.***>; 发送时间: 2022年7月28日(星期四) 晚上8:20 ***@***.***>; 抄送: "I'm ~ ***@***.******@***.***>; 主题: Re:...

Yes, that's it. A flink task can synchronize the data of the entire database ------------------ 原始邮件 ------------------ 发件人: "apache/doris" ***@***.***>; 发送时间: 2022年7月28日(星期四) 晚上8:31 ***@***.***>; 抄送: "I'm ~ ***@***.******@***.***>; 主题: Re: [apache/doris] [Feature] JSON data is...

After the function development is completed, a reference threshold can be given to users. Users can set sink concurrency and checkpoint interval according to scenarios such as data volume and...

> > Many users put all the canal logs of all tables in the business library into one topic, which needs to be distributed before they can use doris-flink-connector. His...