Newbie question, I have a DataStream<MyPoJo>, I like to convert it to a DataStream<Row> or DataStream<RowData> in order to write out to iceberg. Is there a convenience method in the flink api to automatically do this? MyPojo in this my case can be hundreds of different classes. Thanks

@Wai Chee Yau did you get a good answer for this, I am also trying to do the same.

no didnt really get an answer to this

is there an answer to this ?