DBScholar

Back to papers

Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark

Summary: Declarative Spark Structured Streaming; incrementalizes SQL/DataFrame queries, not user-built DAG. End-to-end real-time apps unifying streaming with batch analytics; code generation yields high performance; rollbacks and mixed execution in production. (summarized by gpt-5-nano on Feb 09 2026)

Paper ID
h555c736ba9391777
Venue
SIGMOD
Year
2018
Pagerank
0.00011887295
Overall Rank
1,128 | 92.45%
DOI
10.1145/3183713.3190664

Incoming Non-self Citations Over Time

Authors

BibTeX Citation

@inproceedings{armbrust_sigmod18,
        title = {{Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark}},
        author = {Armbrust, Michael and Das, Tathagata and Torres, Joseph and Yavuz, Burak and Zhu, Shixiong and Xin, Reynold and Ghodsi, Ali and Stoica, Ion and Zaharia, Matei},
        series = {{SIGMOD} '18},
        booktitle = {Proceedings of the {ACM} {SIGMOD} International Conference on Management of Data},
        publisher = {Association for Computing Machinery},
        doi = {10.1145/3183713.3190664},
        url = {https://dl.acm.org/doi/10.1145/3183713.3190664},
        year = {2018}
}

Incoming Citations (Sorted by Pagerank)

Showing 39 of 39 citing papers.

Rank Citing Paper Year Venue Pagerank
462 Delta Lake: High-Performance ACID Table Storage over Cloud Object Stores 2020 VLDB 0.00017825062
3,409 Megaphone: Latency-conscious state migration for distributed streaming dataflows 2019 VLDB 7.3076317e-05
4,889 Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows 2021 SIGMOD 6.3513193e-05
4,908 One SQL to Rule Them All – an Efficient and Syntactically Idiomatic Approach to Management of Streams and Tables 2019 SIGMOD 6.3470129e-05
4,942 LightSaber: Efficient Window Aggregation on Multi-core Processors 2020 SIGMOD 6.3309707e-05
5,246 Babelfish: Efficient Execution of Polyglot Queries 2022 VLDB 6.1985833e-05
6,189 Helios: Hyperscale Indexing for the Cloud & Edge 2020 VLDB 5.8391363e-05
6,240 Providing Streaming Joins as a Service at Facebook 2018 VLDB 5.8234435e-05
6,281 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 5.8083033e-05
6,607 AStream: Ad-hoc Shared Stream Processing 2019 SIGMOD 5.7187564e-05
6,809 Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentile 2021 VLDB 5.660585e-05
7,289 What's the Difference? Incremental Processing with Change Queries in Snowflake 2023 SIGMOD 5.5487732e-05
8,035 AJoin: Ad-hoc Stream Joins at Scale 2020 VLDB 5.3866645e-05
8,427 Spur: Mitigating Slow Instances in Large-Scale Streaming Pipelines 2020 SIGMOD 5.3184107e-05
8,449 Correctness in Stream Processing: Challenges and Opportunities 2022 CIDR 5.3148581e-05
8,705 Prompt: Dynamic Data-Partitioning for Distributed Micro-batch Stream Processing Systems 2020 SIGMOD 5.2707935e-05
8,891 Optimization of Threshold Functions over Streams 2021 VLDB 5.2423828e-05
8,983 FishStore: Faster Ingestion with Subset Hashing 2019 SIGMOD 5.2317424e-05
9,260 Streaming Democratized: Ease Across the Latency Spectrum with Delayed View Semantics and Snowflake Dynamic Tables 2025 SIGMOD 5.1860131e-05
9,851 Scabbard: Single-Node Fault-Tolerant Stream Processing 2022 VLDB 5.1064323e-05
9,873 [Demo] Low-latency Spark Queries on Updatable Data 2019 SIGMOD 5.1052165e-05
9,958 GeaFlow: A Graph Extended and Accelerated Dataflow System 2023 SIGMOD 5.0910746e-05
10,197 Railgun: managing large streaming windows under MAD requirements 2021 VLDB 5.0514463e-05
10,259 Towards Resource-adaptive Query Execution in Cloud Native Databases 2024 CIDR 5.0381136e-05
10,263 TreeCat: Standalone Catalog Engine for Large Data Systems 2025 VLDB 5.0380426e-05
10,313 Chukonu: A Fully-Featured High-Performance Big Data Framework that Integrates a Native Compute Engine into Spark 2022 VLDB 5.0264591e-05
10,640 Enjima: A Resource-Adaptive Stream Processing System 2026 SIGMOD 4.9605343e-05
10,800 Scarf: Self-Adaptive Tuning via Multi-Objective Reinforcement Learning for Apache Flink 2026 VLDB 4.9605343e-05
10,804 APEROL: Adaptive Parallel Edge-to-cloud Runtime Optimization for Layered Workflow Execution 2026 VLDB 4.9605343e-05
10,838 IncreQueryFusion: On-demand Data Fusion Framework in Dynamic Data Lakes 2026 VLDB 4.9605343e-05
10,916 Meerkat: Scalable, Network-Aware Failure Recovery for the Internet of Things 2026 VLDB 4.9605343e-05
10,932 Fugue: Online Elasticity for Distributed Stateful Stream Processing 2026 VLDB 4.9605343e-05
10,997 A Decade of Apache Spark Structured Streaming: How We Evolved The Architecture To Meet Real-World Needs 2026 VLDB 4.9605343e-05
11,106 The Dataflow Model Revisited Or: That Feeling When You Realize Every Problem You've Been Solving Is a Database Problem 2026 VLDB 4.9605343e-05
11,267 Styx: Transactional Stateful Functions on Streaming Dataflows 2025 SIGMOD 4.9605343e-05
11,312 Agamotto: Scheduling of Deadline-Oriented Incremental Query Execution under Uncertain Resource Price 2025 VLDB 4.9605343e-05
11,576 Fault Tolerance Placement in the Internet of Things 2024 SIGMOD 4.9605343e-05
11,805 Fries: Fast and Consistent Runtime Reconfiguration in Dataflow Systems with Transactional Guarantees 2023 VLDB 4.9605343e-05
12,057 Approximating Median Absolute Deviation with Bounded Error 2021 VLDB 4.9605343e-05
Previous Page 1 / 1 Next

Outgoing Citations (Sorted by Pagerank)

Showing 10 of 10 cited papers.

Citations counted here include only citations to other VLDB/SIGMOD/CIDR/PODS papers in this database.

Previous Page 1 / 1 Next

Semantically Similar Papers