Hi y'all! Hoping to get some pointers/tips on an issue I'm facing. Currently, our team is working on building a streaming platform for data engineers to build streaming pipelines quickly and with low-code. A very specific problem that I'm facing is figuring out how to sink a DataStream<Row> as a parquet to a FileSink. I'm able to create a FileSink of RowData using ParquetRowDataBuilder for the ParquetWriterFactory but unsure how to get a FileSink of Row. I think a lot of my confusion stems from understanding the difference between Row and RowData. Sorry if all of these questions are elementary! I would appreciate any documentation/tips/lead. Thank you 🙂

You can convert between Row and RowData with

org.apache.flink.table.data.conversion.RowRowConverter