2024-06-16 09:06:45
866
587
以上，介绍了Flink 支持的数据格式中的csv和json，并分别以sql和table api作为示例进行了说明。本文介绍了Flink 支持的数据格式中的csv和json，并分别以sql和table api作为示例进行了说明。本文的示例是在Flink 1.17版本（flink 集群和maven均是Flink 1.17）中运行。参考上文中关于CSV Format的table api 建表示例，变化的是json的格式参数。下表列出了 Flink 中的数据类型与 JSON 中的数据类型的映射关系。_flink 的 formats 之csv 和 json format