Hi all,
I currently get a json string from my pgsql source with nested objects to
be converted into Flink's Row.
Nested json objects should go in nested Rows.
An avro schema rules the structure my source should conform to.
According to this json :
{
"a":"b",
"c":"d",
"e":{
"f":"g"
}
}
("b", "d", Row("g")) is expected as a result according to my avro schema.
I wrote a recursive method which iterate over json objects and put nested
Rows at right indices in their parent but here is what outputs : ("b", "d",
"g")
Child Row is appended to the parent. I don't understand why.
Obviously, process is crashing arguing the top level Row arity doesn't
match serializers.
Is there some native methods in Flink to achieve that?
I don't feel so comfortable to have written my own json processor for this
job.
Do you have any hint which can help please ?
All the best
François
--
<http://www.dcbrain.com/> <https://twitter.com/dcbrain_feed?lang=fr>
<https://www.linkedin.com/company/dcbrain>
<https://www.youtube.com/channel/UCSJrWPBLQ58fHPN8lP_SEGw>
Pensez à la
planète, imprimer ce papier que si nécessaire
