github.com/datafusion-contrib/StreamFusion
Hi all, I just wanted to give a brief update on this project!
1. StreamFusion now supports the majority of SQL operators
2. StreamFusion achieves better performance than stock Flink in all local NexMark benchmark runs using exactly once semantics, with a kafka source/sink, and both in memory/local disk backends
3. After getting this project into a sufficient "alpha" state, I'll implement some more sink connectors (iceberg, paimon, etc) to try and get more adoption here
Please let me know if you have any questions about the project or if you want to try it out/contribute, I'd be happy to chat!