| 1,546 |
Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark |
2018 |
SIGMOD |
0.00011418993 |
| 1,616 |
Realtime Data Processing at Facebook |
2016 |
SIGMOD |
0.00011133818 |
| 2,339 |
Samza: Stateful Scalable Stream Processing at LinkedIn |
2017 |
VLDB |
9.0029559e-05 |
| 2,860 |
Timon: A Timestamped Event Database for Efficient Telemetry Data Processing and Analytics |
2020 |
SIGMOD |
8.0042474e-05 |
| 3,335 |
SnappyData: A Unified Cluster for Streaming, Transactions, and Interactive Analytics |
2017 |
CIDR |
7.2023806e-05 |
| 3,344 |
F1 Query: Declarative Querying at Scale |
2018 |
VLDB |
7.1944106e-05 |
| 3,363 |
Lethe: A Tunable Delete-Aware LSM Engine |
2020 |
SIGMOD |
7.1680649e-05 |
| 3,551 |
Chi: A Scalable and Programmable Control Plane for Distributed Stream Processing Systems |
2018 |
VLDB |
6.9776252e-05 |
| 4,026 |
Parallel Algorithms for Constructing Range and Nearest-Neighbor Searching Data Structures |
2016 |
PODS |
6.5166769e-05 |
| 4,051 |
Megaphone: Latency-conscious state migration for distributed streaming dataflows |
2019 |
VLDB |
6.4932782e-05 |
| 4,490 |
Analyzing Efficient Stream Processing on Modern Hardware |
2019 |
VLDB |
6.137834e-05 |
| 4,797 |
Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines |
2020 |
SIGMOD |
5.9101178e-05 |
| 4,824 |
Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka |
2021 |
SIGMOD |
5.8902451e-05 |
| 5,131 |
One SQL to Rule Them All – an Efficient and Syntactically Idiomatic Approach to Management of Streams and Tables |
2019 |
SIGMOD |
5.6704313e-05 |
| 5,292 |
StreamOps: Cloud-Native Runtime Management for Streaming Services in ByteDance |
2023 |
VLDB |
5.5784769e-05 |
| 5,357 |
LightSaber: Efficient Window Aggregation on Multi-core Processors |
2020 |
SIGMOD |
5.5512343e-05 |
| 5,740 |
TcpRT: Instrument and Diagnostic Analysis System for Service Quality of Cloud Databases at Massive Scale in Real-time |
2018 |
SIGMOD |
5.3451127e-05 |
| 6,133 |
Optimal and General Out-of-Order Sliding-Window Aggregation |
2019 |
VLDB |
5.1917864e-05 |
| 6,241 |
Helios: Hyperscale Indexing for the Cloud & Edge |
2020 |
VLDB |
5.1357476e-05 |
| 6,430 |
Providing Streaming Joins as a Service at Facebook |
2018 |
VLDB |
5.0587634e-05 |
| 6,628 |
A Holistic View of Stream Partitioning Costs |
2017 |
VLDB |
4.9833118e-05 |
| 6,726 |
Beyond Analytics: The Evolution of Stream Processing Systems |
2020 |
SIGMOD |
4.9444528e-05 |
| 6,760 |
AStream: Ad-hoc Shared Stream Processing |
2019 |
SIGMOD |
4.9304882e-05 |
| 6,769 |
Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow |
2021 |
VLDB |
4.9274854e-05 |
| 6,914 |
CYADB: A Database that Covers Your Ask |
2018 |
VLDB |
4.8878659e-05 |
| 7,371 |
Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentile |
2021 |
VLDB |
4.744863e-05 |
| 7,397 |
Intermittent Query Processing |
2019 |
VLDB |
4.7367491e-05 |
| 7,600 |
Quill: Efficient, Transferable, and Rich Analytics at Scale |
2016 |
VLDB |
4.697054e-05 |
| 7,709 |
Ananke: A Streaming Framework for Live Forward Provenance |
2021 |
VLDB |
4.667502e-05 |
| 8,004 |
Rethinking Stateful Stream Processing with RDMA |
2022 |
SIGMOD |
4.6048388e-05 |
| 8,142 |
Erebus: Explaining the Outputs of Data Streaming Queries |
2023 |
VLDB |
4.5724134e-05 |
| 8,214 |
Spur: Mitigating Slow Instances in Large-Scale Streaming Pipelines |
2020 |
SIGMOD |
4.5524768e-05 |
| 8,594 |
Prompt: Dynamic Data-Partitioning for Distributed Micro-batch Stream Processing Systems |
2020 |
SIGMOD |
4.4844961e-05 |
| 9,027 |
CrocodileDB in Action: Resource-Efficient Query Execution by Exploiting Time Slackness |
2020 |
VLDB |
4.4011428e-05 |
| 9,126 |
Differentially Private Stream Processing at Scale* |
2024 |
VLDB |
4.3870625e-05 |
| 9,191 |
POLAR: Adaptive and Non-invasive Join Order Selection via Plans of Least Resistance |
2024 |
VLDB |
4.3738237e-05 |
| 9,220 |
Elasticutor: Rapid Elasticity for Realtime Stateful Stream Processing |
2019 |
SIGMOD |
4.3670162e-05 |
| 9,323 |
Disaggregated State Management in Apache Flink® 2.0 |
2025 |
VLDB |
4.351469e-05 |
| 9,407 |
Vortex: A Stream-oriented Storage Engine For Big Data Analytics |
2024 |
SIGMOD |
4.3399748e-05 |
| 9,604 |
GeaFlow: A Graph Extended and Accelerated Dataflow System |
2023 |
SIGMOD |
4.3136057e-05 |
| 9,800 |
Dalton: Learned Partitioning for Distributed Data Streams |
2023 |
VLDB |
4.2777144e-05 |
| 9,806 |
Railgun: managing large streaming windows under MAD requirements |
2021 |
VLDB |
4.2766788e-05 |
| 9,880 |
VStream: A Distributed Streaming Vector Search System |
2025 |
VLDB |
4.2602815e-05 |
| 10,077 |
Enjima: A Resource-Adaptive Stream Processing System |
2026 |
SIGMOD |
4.1905499e-05 |
| 10,183 |
Mixtera: A Data Plane for Foundation Model Training |
2026 |
SIGMOD |
4.1905499e-05 |
| 10,259 |
Scarf: Self-Adaptive Tuning via Multi-Objective Reinforcement Learning for Apache Flink |
2026 |
VLDB |
4.1905499e-05 |
| 10,421 |
Oceanus: Enable SLO-Aware Vertical Autoscaling for Cloud-Native Streaming Services in Tencent |
2025 |
SIGMOD |
4.1905499e-05 |
| 10,427 |
Streaming Democratized: Ease Across the Latency Spectrum with Delayed View Semantics and Snowflake Dynamic Tables |
2025 |
SIGMOD |
4.1905499e-05 |
| 10,624 |
Unraveling the Impact of Window Semantics: Optimizing Join Order for Efficient Stream Processing |
2025 |
VLDB |
4.1905499e-05 |
| 10,772 |
Scribe: How Meta transports terabytes per second in real time |
2025 |
VLDB |
4.1905499e-05 |