NIFI 中的列值检查

【问题标题】：Column value checking in NIFINIFI 中的列值检查
【发布时间】：2021-12-27 13:59:13
【问题描述】：

我想检查我的 CSV 文件上的列是否有值&基于我必须执行两个单独的任务，任何特定的方式来实现它

【问题讨论】：

例如，使用 nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/… 将文件拆分为两个较小的文件，并对结果文件应用不同的处理器

【解决方案1】：

我关注this的帖子并做了一个例子

数据：

Id,Name,Surname
1,name1,surname1
2,name2,surname2
3,,surname3

架构：

{"type":"record",
"name":"person",
"namespace":"any.data",
"fields":
[{"name":"Surname","type":["string"]},
{"name":"Name","type":["string"]},
{"name":"Id","type":["int"]}]}

流程：

查询记录：

查看QueryRecord's usage

查看Calcite's reference

【讨论】：