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
5559
Venue
SIGMOD
Year
2018
Pagerank
0.00011743246
Overall Rank
1,190 | 91.84%
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 35 of 35 citing papers.

Rank Citing Paper Year Venue Pagerank
520 Delta Lake: High-Performance ACID Table Storage over Cloud Object Stores 2020 VLDB 0.00017136828
3,531 Megaphone: Latency-conscious state migration for distributed streaming dataflows 2019 VLDB 7.337549e-05
4,820 LightSaber: Efficient Window Aggregation on Multi-core Processors 2020 SIGMOD 6.493623e-05
4,907 One SQL to Rule Them All – an Efficient and Syntactically Idiomatic Approach to Management of Streams and Tables 2019 SIGMOD 6.4494002e-05
5,301 Babelfish: Efficient Execution of Polyglot Queries 2022 VLDB 6.2750553e-05
5,756 Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows 2021 SIGMOD 6.097233e-05
6,045 Helios: Hyperscale Indexing for the Cloud & Edge 2020 VLDB 5.9957544e-05
6,108 Providing Streaming Joins as a Service at Facebook 2018 VLDB 5.9730511e-05
6,482 AStream: Ad-hoc Shared Stream Processing 2019 SIGMOD 5.8668582e-05
6,680 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 5.8049764e-05
7,294 Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentile 2021 VLDB 5.6532162e-05
7,856 AJoin: Ad-hoc Stream Joins at Scale 2020 VLDB 5.5306709e-05
8,258 Correctness in Stream Processing: Challenges and Opportunities 2022 CIDR 5.4574671e-05
8,309 Spur: Mitigating Slow Instances in Large-Scale Streaming Pipelines 2020 SIGMOD 5.4560857e-05
8,568 Prompt: Dynamic Data-Partitioning for Distributed Micro-batch Stream Processing Systems 2020 SIGMOD 5.4118703e-05
8,697 Optimization of Threshold Functions over Streams 2021 VLDB 5.3830471e-05
8,799 FishStore: Faster Ingestion with Subset Hashing 2019 SIGMOD 5.369237e-05
9,050 Streaming Democratized: Ease Across the Latency Spectrum with Delayed View Semantics and Snowflake Dynamic Tables 2025 SIGMOD 5.3251649e-05
9,064 What's the Difference? Incremental Processing with Change Queries in Snowflake 2023 SIGMOD 5.3251649e-05
9,633 Scabbard: Single-Node Fault-Tolerant Stream Processing 2022 VLDB 5.2434488e-05
9,655 [Demo] Low-latency Spark Queries on Updatable Data 2019 SIGMOD 5.2422003e-05
9,738 GeaFlow: A Graph Extended and Accelerated Dataflow System 2023 SIGMOD 5.227679e-05
9,968 Railgun: managing large streaming windows under MAD requirements 2021 VLDB 5.1869874e-05
10,039 Towards Resource-adaptive Query Execution in Cloud Native Databases 2024 CIDR 5.1723558e-05
10,076 Chukonu: A Fully-Featured High-Performance Big Data Framework that Integrates a Native Compute Engine into Spark 2022 VLDB 5.1613298e-05
10,368 Enjima: A Resource-Adaptive Stream Processing System 2026 SIGMOD 5.093636e-05
10,547 Scarf: Self-Adaptive Tuning via Multi-Objective Reinforcement Learning for Apache Flink 2026 VLDB 5.093636e-05
10,551 APEROL: Adaptive Parallel Edge-to-cloud Runtime Optimization for Layered Workflow Execution 2026 VLDB 5.093636e-05
10,579 Meerkat: Scalable, Network-Aware Failure Recovery for the Internet of Things 2026 VLDB 5.093636e-05
10,782 Styx: Transactional Stateful Functions on Streaming Dataflows 2025 SIGMOD 5.093636e-05
10,842 Agamotto: Scheduling of Deadline-Oriented Incremental Query Execution under Uncertain Resource Price 2025 VLDB 5.093636e-05
10,976 TreeCat: Standalone Catalog Engine for Large Data Systems 2025 VLDB 5.093636e-05
11,176 Fault Tolerance Placement in the Internet of Things 2024 SIGMOD 5.093636e-05
11,443 Fries: Fast and Consistent Runtime Reconfiguration in Dataflow Systems with Transactional Guarantees 2023 VLDB 5.093636e-05
11,703 Approximating Median Absolute Deviation with Bounded Error 2021 VLDB 5.093636e-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