How this analysis was created: This summary and feature list are AI-generated from collected project material and can contain mistakes. Stars, license and language are imported from GitHub. Inclusion does not mean that we have tested or audited this project. Check the source documentation for any feature you depend on. Learn more on our About page.
Continuous Query Language (CQL) is a query language used for data streams. Compared with traditional SQL, CQL introduces the concept of window. Data is stored in memory so that in-memory computing can be quickly implemented. CQL query results are computing results at a specific moment of data…
The main features of zhiqiang-he/streamcql are: Streaming SQL.
Projects with overlapping indexed features include: apache/flink — Apache Flink is a distributed processing engine designed for both high-throughput, low-latency data streams and finite… arroyosystems/arroyo — Arroyo is a high-performance stream processing platform built in Rust. It executes continuous SQL queries on streaming… confluentinc/ksql — The database purpose-built for stream processing applications. epfldata/squall — A streaming / online query processing / analytics engine based on Apache Storm. laminardb/laminardb — Open-source streaming SQL engine written in Rust using Apache Arrow and DataFusion. Supports continuous queries,… pipelinedb/pipelinedb — High-performance time-series aggregation for PostgreSQL.
Apache Flink is a distributed processing engine designed for both high-throughput, low-latency data streams and finite batch workloads. It functions as a stateful stream processor and a SQL stream processing engine, providing a unified runtime to execute relational queries and event-based transformations. The system is distinguished by its ability to manage persistent operator state to ensure exactly-once processing guarantees and consistency during failures. It features specialized capabilities for complex event processing to detect temporal patterns and handles out-of-order events using eve
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
The database purpose-built for stream processing applications.
A streaming / online query processing / analytics engine based on Apache Storm