Flink 1.14 Scala 2.12.5 Hi, I want to be able to convert a Table into a DataStream[RowData]. I need to do this since I already have specific infrastructure in place that knows how to serialize RowData into a JSON format. Previously when using toAppendStream[RowData], this worked fine.
However, now with the new toDataStream API, I don't see a direct way to do this. Using toDataStream[RowData](tableSchema.toPhysicalRowDataType) still creates an internal OutputConversionOperator and yields a Row to the Kafka sink I'm trying to use. Would love some help. -- Best Regards, Yuval Itzchakov.
