Hello,
I want to make the input record be the content of a field in the output record.
Can this be achieved with the Flink-SQL DSL?
Let's say I'm getting an input that looks like this:
{
...
"fields": [{
"name": "intField",
"type": "int"
}, {
"name": "stringField",
"type": "string"
}]
}
Is it possible to transform it, using SQL, to something like this:
{
....
"fields": [{
"name": "payload",
"type": {
"type": "record",
"name": "Schema",
"namespace": "line4.read.iw.iw",
"fields": [{
"name": "intField",
"type": "int"
}, {
"name": "stringField",
"type": "string"
}]
}
}]
}
If not are there any alternatives?
