github.com/datafusion-contrib/StreamFusion
Wanted to flag that StreamFusion now supports an Apache Paimon source and sink! These are accelerated flink SQL jobs for writing to open table formats (paimon also has a mode to write iceberg metadata on top of its own tables!!). Feel free to star the repo if you're interested or reach out to me!