NIFI 中的列值检查
Posted
技术标签:
【中文标题】NIFI 中的列值检查【英文标题】：Column value checking in NIFI 【发布时间】：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
【讨论】：
以上是关于NIFI 中的列值检查的主要内容，如果未能解决你的问题，请参考以下文章