@kirilldemidov Your spec works only if your input is a json object and not json array. For your spec to work on all the records, you have to perform the same operation(your spec) on each record. This can be done as follows: [ { "operation": "shift", "spec": { "*":{ "id": "[&1].id", "event_id": "[&1].event_id", "formula_id": "[&1].formula_id", "ts_start": "[&1].ts_start", "ts_end": "[&1].ts_end", "type": "[&1].type", "details": { "*": { "$": "[&3].equipment_id", "*": { "$": "[&4].parameter", "@": "[&4].value" } } }, "ack_ts": "[&1].ack_ts", "ack_user": "[&1].ack_user" } } } ] Here, "&1" means go one level up in the spec. In [&1].id &1 points to *. '*' is the iteration step value, meaning, index of the input array. For the first record, it will be [1].id,[1].event_id,..... Similarly, &3 (or) &4 means go 3 (or) 4 levels up, so that it points to the same *. Also, try another spec: [
{
"operation": "shift",
"spec": {
"*": {
"details": {
"*": {
"$": "[&3].equipment_id",
"*": {
"$": "[&4].parameter",
"@": "[&4].value"
}
}
},
"*": "[&1].&0"
}
}
}
] The * after "details" ends refers to all the keys in the input json other than "details" key. For further clarifications, refer to https://community.cloudera.com/t5/Community-Articles/Jolt-quick-reference-for-Nifi-Jolt-Processors/tac-p/244351#M407
... View more
