TLDR Tech / Data
StreamFusion (GitHub Repo)
StreamFusion is an OSS Flink SQL accelerator that transparently swaps supported streaming operators for native Rust/Apache Arrow/DataFusion execution over JNI while leaving Flink responsible for planning, coordination, and fallback. It targets full columnar “islands” across projection, filters, windowed aggregates, joins, changelog operations, Kafka/file connectors, and scalar UDFs called back into the JVM, with byte-identical parity as the default.
Read the full story