使用 Apache NiFi 替换列值

Question

我有一个示例 csv 看起来像这样

ID,FNAME,PROBLEM_COL
1,sachith,
2,nalaka,
3,john,
4,adams,

始终PROBLEM_COL 值为空。我想用 null 字符串替换空值。

为此我使用了 UpdateRecord 处理器和 CSVReader 以及 Use String Fields From Headers
自定义值为 /PROBLEM_COL 和 ${field.value:replaceFirst('','null')}

这在没有 error/warning 的情况下运行。但是 PROBLEM_COL 没有被替换。我已经提到，但这并不能解决我的问题。我的 headers 在 block-letters.

Answer 1

尝试将您的正则表达式更改为

',$'

这意味着：逗号后跟行尾

Answer 2

使用 replaceEmpty('null') 而不是 replaceFirst

Answer 3

处理器 UpdateRecord 你可以使用

replace( /PROBLEM_COL, '', 'null' )

Replace column values using Apache NiFi