请问如何用datastream API实现Mysql到hudi的数据同步，并且支持动态的shema #1682
Unanswered
xingyunyang01
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
我现在有一个需求，需要做一个通用化的mysql入hudi的软件，实现用户只需要指定数据库/表名以及主键名称，就可以入hudi，而无需指定schema，因此需要用datastream实现。我研究了一下hudi官方的例子，大概思路就是先从mysql source数据变成string类型，然后fromsource时，将string转成rowdata。但是这块转换的代码，我不知道怎么写能实现动态schema的转换。有没有大神给个例子 我参考一下
Beta Was this translation helpful? Give feedback.
All reactions