search

ivi-ru / flink-clickhouse-sink

Flink sink for Clickhouse
MIT License
369 stars 126 forks source link

How to insert an csv row into a clickhouse db.table? #6

Closed JoshuaYin closed 4 years ago

JoshuaYin commented 4 years ago

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 4 years ago

@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 4 years ago

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 4 years ago

ok, closing this issue