如果对象的一个字段为空,我如何使用NIFI中的JoltTransformJson处理器转换(在本例中为删除)流文件
下面是我的数据.
_
[
{
"Name" : "john Smith",
"DOB" : "2000-07-14",
"Salary" : 16000.0
},
{
"Name" : "Sara Jacob",
"DOB" : "2000-07-14",
"Salary" : 12000.0
},
{
"Name" : "Peter John",
"DOB" : null,
"Salary" : 20000.0
},
{
"Name" : "Lia Poul",
"DOB" : "2000-07-14",
"Salary" : 18000.0
}
]
我使用100处理器将JSON文件拆分成多个独立的FlowFiles,并将下游连接到101处理器.接下来,我将JoltTransformJson配置如下: 抖动变换DSL:链 Jolt规格:
[
{
"operation": "remove",
"spec": {
"rowsToRemove": {
"*": {
"DOB": {
"$null": ""
}
}
}
}
}
]
但是这个表达式只删除了道布字段,而不是整个对象和流文件.