How to insert an csv row into a clickhouse db.table?
Closed this issue · 3 comments
JoshuaYin commented
I read data from Kafka and transfer data into clickhouse with flink.
And the data is csv row String, the data format on clickhouse is DB.
mchernyakov commented
@JoshuaYin so, let me clarify, you are reading data from kafka and the format is CSV (String), and you want to send these rows to Clickhouse, correct?
Have you tried to implement your own converter, as we have in the example? https://github.com/ivi-ru/flink-clickhouse-sink#in-code
JoshuaYin commented
emmmmm,I've resolve the problem with the method like implement my own converter.
Thx~
By the way, the sink is so convenient~
mchernyakov commented
ok, closing this issue