Im-Manshushu commented on issue #11258:
URL: https://github.com/apache/doris/issues/11258#issuecomment-1197626618
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 directly, view it on GitHub, or unsubscribe.
You are receiving this because you authored the thread.Message ID:
***@***.***>
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
