Re: Flink SQL JSON

2022-11-20 Thread yuxia
Hi! Maybe you can map it to Flink's BINARY / VARBINARY type [1]. [1] https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/formats/json/#data-type-mapping Best regards, Yuxia 发件人: "Timothy Bess" 收件人: "User" 发送时间: 星期六, 2022年 11 月 19日

Flink SQL JSON

2022-11-18 Thread Timothy Bess
Hi Flink Users, I use Flink SQL to ETL Kafka event data into tables we use for analysis, and I'm currently trying to use it to basically extract a few fields out of some JSON, but leave the original blob in a subdocument using the elasticsearch connector. I see that there is `ROW` and `MAP` but I