1 dépôt
Defines new data streams from SQL queries with automatic schema inference from the query result.
Distinct from Streaming SQL Transformations: Distinct from Streaming SQL Transformations: focuses on creating named derived streams with inferred schemas, not just executing transformation queries.
Explore 1 awesome GitHub repository matching data & databases · Derived Stream Definitions. Refine with filters or upvote what's useful.
Arroyo is a high-performance stream processing platform built in Rust. It executes continuous SQL queries on streaming data with event-time semantics, enabling accurate windowed aggregations, joins, and stateful computations on unbounded event streams. The platform uses native Rust execution for high throughput and low latency, with periodic checkpointing for exactly-once fault tolerance and horizontal scaling across distributed workers. The system integrates deeply with Kafka for reading and writing topics with exactly-once delivery and supports change data capture (CDC) from MySQL and Postg
Defines new data streams from SQL queries with automatic schema inference from the query result.