[NIFI-4227] Create a ForkRecord processor

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.7.0
• Component/s: Extensions
• Assignee: Pierre Villard
• Reporter: Pierre Villard
• Created: 25/Jul/17 15:41
• Updated: 25/May/18 06:13
• Resolved: 24/May/18 19:59

Description

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:

[{
	"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
	}]
}]

Then, I want to generate records looking like:

[{
	"id": 42,
	"balance": 4750.89
}, {
	"id": 43,
	"balance": 48212.38
}, {
	"id": 45,
	"balance": 6578.45
}, {
	"id": 46,
	"balance": 34567.21
}]

Or, if parent fields are included, looking like:

[{
	"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
}]

Issue Links

• is duplicated by: NIFI-4226 Create a ForkRecord processor
• links to: GitHub Pull Request #2037