NIFI-10865 allow RecordPath's unescapeJson to convert de-serialised JSON Objects into Records

[ChrisSamo632]

Summary

NIFI-10865 allow RecordPath's unescapeJson to convert de-serialised JSON Objects into Records

NIFI-10865 allow UpdateRecord to replace the Record root for relative paths, e.g. when a RecordPath function is used to modify selected field(s)

Tracking

Please complete the following tracking steps prior to pull request creation.

Issue Tracking

• Apache NiFi Jira issue created

Pull Request Tracking

• Pull Request title starts with Apache NiFi Jira issue number, such as NIFI-00000
• Pull Request commit message starts with Apache NiFi Jira issue number, as such NIFI-00000

Pull Request Formatting

• Pull Request based on current revision of the main branch
• Pull Request refers to a feature branch with one commit containing changes

Verification

Please indicate the verification steps performed prior to pull request creation.

Build

• Build completed using mvn clean install -P contrib-check
  • JDK 8
  • JDK 11
  • JDK 17

Licensing

• [ ] New dependencies are compatible with the Apache License 2.0 according to the License Policy
• [ ] New dependencies are documented in applicable LICENSE and NOTICE files

Documentation

• Documentation formatting appears as expected in rendered files`

[MikeThomsen]

It does not appear to work if the schema contains a child element. Tested this schema and JSON with UpdateRecord using /embedded and unescapeJson(/str) as the configured update and got an exception:

Schema:

{
	"name": "Parent",
	"type": "record",
	"fields": [{
			"name": "str",
			"type": "string"
		},
		{
			"name": "embedded",
			"type": [{
				"name": "EmbeddedRecord",
				"type": "record",
				"fields": [{
						"name": "label",
						"type": "string"
					},
					{
						"name": "child",
						"type": {
							"name": "ChildRecord",
							"type": "record",
							"fields": [{
								"name": "name",
								"type": "string"
							}]
						}
					}
				]
			}, "null"]
		}
	]
}

Data:

{
	"str": "{\"label\":\"Test!\",\"child\":{\"name\":\"Child record!\"}}",
	"embedded": null
}

[ChrisSamo632]

@MikeThomsen I rebased on main latest and added a new TestUpdateRecord unit test (testSetNestedRecordWithUnescapeJsonCall) based on the example you provided and it seems to work without issue. Can you take a look and see whether the test is setup any differently to what you were trying?

If you still get an error, can you elaborate with the meagre and/or stacktrace?

[MikeThomsen]

I don't know what I did that first round, but you were right. I went back and did it over from scratch, and it worked.