我正在Nifi
中使用*JOLTTransformJson*处理器。
我的输入是:
[
{
"col_name": "time",
"data_type": "timestamp",
"is_nullable": true
},
{
"col_name": "otherData",
"data_type": "string",
"is_nullable": false
}
]
我正在使用以下规格:
[
{
"operation": "shift",
"spec": {
"*": {
"col_name": "name",
"data_type": "type[0]",
"is_nullable": {
"true": "type[1]",
"false": "type[1]"
}
}
}
},
{
"operation": "default",
"spec": {
"*": {
"type[1]": "notnull"
}
}
}
]
预期输出为:
{
"type": "record",
"name": "table_name",
"fields": [
{
"name": "time",
"type": [
"timestamp",
"null"
]
},
{
"name": "otherData",
"type": [
"string",
"notnull"
]
}
]
}
但是通过组合数组中的所有值,将下面的值作为当前结果,如下所示:
{
"name": [
"time",
"otherData"
],
"type": [
[
"timestamp",
"int"
],
null
]
}
有人能帮帮我吗。
1条答案
按热度按时间fnvucqvd1#
通过遍历数组的对象,您可以使用以下第一个shift转换规范,以便能够 * 重复 * 应用这些技术:
第二个和第三个转换只是添加到排序所需属性/数组