Flink:如何在 Flink 中处理 Null 值,尤其是在读取 CSV 等文件时。
我来自火花背景。所以火花中有空处理。像 df.na.fill 等
所以我想知道 Dataset API 中是否有这样的工具,或者唯一的方法是使用 map 函数。
使用 POJO 而不是 Case Class 更好吗?POJO中启动的默认值是否会在数据文件中缺少该值时生效。
Flink:如何在 Flink 中处理 Null 值,尤其是在读取 CSV 等文件时。
我来自火花背景。所以火花中有空处理。像 df.na.fill 等
所以我想知道 Dataset API 中是否有这样的工具,或者唯一的方法是使用 map 函数。
使用 POJO 而不是 Case Class 更好吗?POJO中启动的默认值是否会在数据文件中缺少该值时生效。