首页 > 解决方案 > Flink:如何在 Flink 中处理 Null 值,尤其是在读取 csv 之类的文件时

问题描述

Flink:如何在 Flink 中处理 Null 值,尤其是在读取 CSV 等文件时。

我来自火花背景。所以火花中有空处理。像 df.na.fill 等

所以我想知道 Dataset API 中是否有这样的工具,或者唯一的方法是使用 map 函数。

使用 POJO 而不是 Case Class 更好吗?POJO中启动的默认值是否会在数据文件中缺少该值时生效。

标签: apache-flinkflink-streamingflink-batch

解决方案


推荐阅读