Embeddable stream processing engine based on Apache DataFusion - View it on GitHub