Quick Question on Flink Is there a way i can replace a value for a nested column in Table API? I am trying to do the following • I want to pick up value from

__event_headers.header_key1

• cast it as String • save it under a nested field.

__event_headers_parsed.header_key1

table.addOrReplaceColumns($("__event_headers").get("header_key1").cast(DataTypes.STRING()).as(s"__event_headers_parsed.header_key1"))

But instead it is creating a new field with

.

and having it in the root as follows. Output i am getting:

{
  "id": 3,
  "name": {
    "firstName": "Jon",
    "lastName": "Doe"
  },
  "__event_headers": {
    "header_key1": "aGVhZGVyX3ZhbHVlMQ==",
    "changeAction": "aGVhZGVyX3ZhbHVl"
  },
  "__event_headers_parsed": null,
  "__event_headers_parsed.header_key1": "header_value"
}

Expected output

{
  "id": 3,
  "name": {
    "firstName": "Jon",
    "lastName": "Doe"
  },
  "__event_headers": {
    "header_key1": "aGVhZGVyX3ZhbHVlMQ==",
    "changeAction": "aGVhZGVyX3ZhbHVl"
  },
  "__event_headers_parsed": {
    "header_key1": "header_value"
  }
}