Pierre Villard created NIFI-4227:
------------------------------------
Summary: Create a ForkRecord processor
Key: NIFI-4227
URL: https://issues.apache.org/jira/browse/NIFI-4227
Project: Apache NiFi
Issue Type: New Feature
Components: Extensions
Reporter: Pierre Villard
Assignee: Pierre Villard
I'd like a way to fork a record containing an array of records into multiple
records, each one being an element of the array. In addition, if configured to,
I'd like the option to add to each new record the parent fields.
For example, if I've:
{noformat}
[{
"id": 1,
"name": "John Doe",
"address": "123 My Street",
"city": "My City",
"state": "MS",
"zipCode": "11111",
"country": "USA",
"accounts": [{
"id": 42,
"balance": 4750.89
}, {
"id": 43,
"balance": 48212.38
}]
},
{
"id": 2,
"name": "Jane Doe",
"address": "345 My Street",
"city": "Her City",
"state": "NY",
"zipCode": "22222",
"country": "USA",
"accounts": [{
"id": 45,
"balance": 6578.45
}, {
"id": 46,
"balance": 34567.21
}]
}]
{noformat}
Then, I want to generate records looking like:
{noformat}
[{
"id": 42,
"balance": 4750.89
}, {
"id": 43,
"balance": 48212.38
}, {
"id": 45,
"balance": 6578.45
}, {
"id": 46,
"balance": 34567.21
}]
{noformat}
Or, if parent fields are included, looking like:
{noformat}
[{
"name": "John Doe",
"address": "123 My Street",
"city": "My City",
"state": "MS",
"zipCode": "11111",
"country": "USA",
"id": 42,
"balance": 4750.89
}, {
"name": "John Doe",
"address": "123 My Street",
"city": "My City",
"state": "MS",
"zipCode": "11111",
"country": "USA",
"id": 43,
"balance": 48212.38
}, {
"name": "Jane Doe",
"address": "345 My Street",
"city": "Her City",
"state": "NY",
"zipCode": "22222",
"country": "USA",
"id": 45,
"balance": 6578.45
}, {
"name": "Jane Doe",
"address": "345 My Street",
"city": "Her City",
"state": "NY",
"zipCode": "22222",
"country": "USA",
"id": 46,
"balance": 34567.21
}]
{noformat}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
