Xff686542 commented on issue #11258: URL: https://github.com/apache/doris/issues/11258#issuecomment-1208119148
> 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 ***@***.***>; 抄送: "I'm ~ ***@***.******@***.***>; 主题: Re: [apache/doris] [Feature] JSON data is dynamically written to the Doris table (Issue #11258) 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, tablename, list<string>. If there is a need to dynamically insert multi table data, the user only needs to encapsulate this entity object, I'm not good at English. I don't know whether I can express it clearly By encapsulating a data structure similar to <db, table, data>, when stream loading, replace the corresponding url, and then stream load the data of each table in turn on the sink side? — Reply to this email dir ectly, view it on GitHub, or unsubscribe. You are receiving this because you authored the thread.Message ID: ***@***.***> That's right, we've done that for now -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org
