Im trying the Iceberg integration for Flink. To write to iceberg table i need to convert my datastream from

DataStream<CustomClass>

to

DataStream<Row>

or

DataStream<RowData>

. Is there a function in Flink to automatically do this? I prefer not to manually map it myself because I'll having a lot of different custom classes from Protobuf. Thanks