| 1,139 |
Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark |
2018 |
SIGMOD |
0.0001209681 |
| 1,387 |
Realtime Data Processing at Facebook |
2016 |
SIGMOD |
0.00011038963 |
| 1,784 |
Samza: Stateful Scalable Stream Processing at LinkedIn |
2017 |
VLDB |
9.8443759e-05 |
| 2,721 |
Lethe: A Tunable Delete-Aware LSM Engine |
2020 |
SIGMOD |
8.2688149e-05 |
| 2,820 |
F1 Query: Declarative Querying at Scale |
2018 |
VLDB |
8.140112e-05 |
| 2,868 |
SnappyData: A Unified Cluster for Streaming, Transactions, and Interactive Analytics |
2017 |
CIDR |
8.0819785e-05 |
| 2,961 |
Chi: A Scalable and Programmable Control Plane for Distributed Stream Processing Systems |
2018 |
VLDB |
7.9686889e-05 |
| 3,277 |
Timon: A Timestamped Event Database for Efficient Telemetry Data Processing and Analytics |
2020 |
SIGMOD |
7.6339617e-05 |
| 3,369 |
Megaphone: Latency-conscious state migration for distributed streaming dataflows |
2019 |
VLDB |
7.5425234e-05 |
| 3,692 |
Parallel Algorithms for Constructing Range and Nearest-Neighbor Searching Data Structures |
2016 |
PODS |
7.2595895e-05 |
| 3,778 |
Analyzing Efficient Stream Processing on Modern Hardware |
2019 |
VLDB |
7.1851487e-05 |
| 4,114 |
Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines |
2020 |
SIGMOD |
6.9553427e-05 |
| 4,318 |
Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka |
2021 |
SIGMOD |
6.8363529e-05 |
| 4,749 |
LightSaber: Efficient Window Aggregation on Multi-core Processors |
2020 |
SIGMOD |
6.5984973e-05 |
| 4,856 |
One SQL to Rule Them All – an Efficient and Syntactically Idiomatic Approach to Management of Streams and Tables |
2019 |
SIGMOD |
6.5414245e-05 |
| 5,465 |
TcpRT: Instrument and Diagnostic Analysis System for Service Quality of Cloud Databases at Massive Scale in Real-time |
2018 |
SIGMOD |
6.276117e-05 |
| 5,708 |
Optimal and General Out-of-Order Sliding-Window Aggregation |
2019 |
VLDB |
6.1797581e-05 |
| 5,729 |
StreamOps: Cloud-Native Runtime Management for Streaming Services in ByteDance |
2023 |
VLDB |
6.170083e-05 |
| 5,930 |
Providing Streaming Joins as a Service at Facebook |
2018 |
VLDB |
6.1000158e-05 |
| 5,958 |
Helios: Hyperscale Indexing for the Cloud & Edge |
2020 |
VLDB |
6.0886149e-05 |
| 6,342 |
A Holistic View of Stream Partitioning Costs |
2017 |
VLDB |
5.9697897e-05 |
| 6,357 |
Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow |
2021 |
VLDB |
5.9654209e-05 |
| 6,403 |
AStream: Ad-hoc Shared Stream Processing |
2019 |
SIGMOD |
5.952729e-05 |
| 6,505 |
Beyond Analytics: The Evolution of Stream Processing Systems |
2020 |
SIGMOD |
5.9144751e-05 |
| 7,091 |
Intermittent Query Processing |
2019 |
VLDB |
5.7589718e-05 |
| 7,161 |
Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentile |
2021 |
VLDB |
5.7442397e-05 |
| 7,383 |
CYADB: A Database that Covers Your Ask |
2018 |
VLDB |
5.6897772e-05 |
| 7,450 |
Ananke: A Streaming Framework for Live Forward Provenance |
2021 |
VLDB |
5.6770418e-05 |
| 7,583 |
Quill: Efficient, Transferable, and Rich Analytics at Scale |
2016 |
VLDB |
5.6487011e-05 |
| 7,687 |
Rethinking Stateful Stream Processing with RDMA |
2022 |
SIGMOD |
5.6249337e-05 |
| 7,978 |
Erebus: Explaining the Outputs of Data Streaming Queries |
2023 |
VLDB |
5.5692809e-05 |
| 8,068 |
Spur: Mitigating Slow Instances in Large-Scale Streaming Pipelines |
2020 |
SIGMOD |
5.5526491e-05 |
| 8,486 |
Prompt: Dynamic Data-Partitioning for Distributed Micro-batch Stream Processing Systems |
2020 |
SIGMOD |
5.4875448e-05 |
| 9,039 |
CrocodileDB in Action: Resource-Efficient Query Execution by Exploiting Time Slackness |
2020 |
VLDB |
5.3909533e-05 |
| 9,089 |
POLAR: Adaptive and Non-invasive Join Order Selection via Plans of Least Resistance |
2024 |
VLDB |
5.3857237e-05 |
| 9,141 |
Differentially Private Stream Processing at Scale* |
2024 |
VLDB |
5.3750713e-05 |
| 9,200 |
Elasticutor: Rapid Elasticity for Realtime Stateful Stream Processing |
2019 |
SIGMOD |
5.3688031e-05 |
| 9,328 |
Disaggregated State Management in Apache Flink® 2.0 |
2025 |
VLDB |
5.3449422e-05 |
| 9,402 |
Vortex: A Stream-oriented Storage Engine For Big Data Analytics |
2024 |
SIGMOD |
5.3341661e-05 |
| 9,592 |
GeaFlow: A Graph Extended and Accelerated Dataflow System |
2023 |
SIGMOD |
5.3086438e-05 |
| 9,790 |
Dalton: Learned Partitioning for Distributed Data Streams |
2023 |
VLDB |
5.2719963e-05 |
| 9,805 |
Railgun: managing large streaming windows under MAD requirements |
2021 |
VLDB |
5.2708329e-05 |
| 9,880 |
VStream: A Distributed Streaming Vector Search System |
2025 |
VLDB |
5.2533454e-05 |
| 10,077 |
Enjima: A Resource-Adaptive Stream Processing System |
2026 |
SIGMOD |
5.1725247e-05 |
| 10,183 |
Mixtera: A Data Plane for Foundation Model Training |
2026 |
SIGMOD |
5.1725247e-05 |
| 10,259 |
Scarf: Self-Adaptive Tuning via Multi-Objective Reinforcement Learning for Apache Flink |
2026 |
VLDB |
5.1725247e-05 |
| 10,421 |
Oceanus: Enable SLO-Aware Vertical Autoscaling for Cloud-Native Streaming Services in Tencent |
2025 |
SIGMOD |
5.1725247e-05 |
| 10,427 |
Streaming Democratized: Ease Across the Latency Spectrum with Delayed View Semantics and Snowflake Dynamic Tables |
2025 |
SIGMOD |
5.1725247e-05 |
| 10,624 |
Unraveling the Impact of Window Semantics: Optimizing Join Order for Efficient Stream Processing |
2025 |
VLDB |
5.1725247e-05 |
| 10,772 |
Scribe: How Meta transports terabytes per second in real time |
2025 |
VLDB |
5.1725247e-05 |