Process Faster, Pay Less: Functional Isolation for Stream Processing
Fuente:
arXiv
Saved in:
| Main Authors: | , , , , |
|---|---|
| Format: | Preprint |
| Published: |
2026
|
| Subjects: | |
| Online Access: | |
| Tags: |
Add Tag
No Tags, Be the first to tag this record!
|
| _version_ | 1866914410009722880 |
|---|---|
| author | Zapridou, Eleni Koepf, Michael Sioulas, Panagiotis Mytilinis, Ioannis Ailamaki, Anastasia |
| author_facet | Zapridou, Eleni Koepf, Michael Sioulas, Panagiotis Mytilinis, Ioannis Ailamaki, Anastasia |
| contents | Concurrent workloads often extract insights from high-throughput, real-time data streams. Existing stream processing engines isolate each query's resources, ensuring robust performance but incurring high infrastructure costs. In contrast, sharing work reduces the amount of necessary resources but introduces inter-query interference, leading to performance degradation for some queries. We introduce FunShare, a stream-processing system that improves resource efficiency without compromising performance by dynamically grouping queries based on their performance characteristics. FunShare strategically relaxes query interdependencies and minimizes redundant computation while preserving individual query performance. It achieves this by using an adaptive optimization framework that monitors execution metrics, accurately estimates computation overlaps, and reconfigures execution plans on the fly in response to changes in the underlying data streams. Our evaluation demonstrates that FunShare minimizes resource consumption compared to isolated execution while maintaining or improving throughput for all queries. |
| format | Preprint |
| id |
arxiv_https___arxiv_org_abs_2603_19445 |
| institution | arXiv |
| publishDate | 2026 |
| record_format | arxiv |
| spellingShingle | Process Faster, Pay Less: Functional Isolation for Stream Processing Zapridou, Eleni Koepf, Michael Sioulas, Panagiotis Mytilinis, Ioannis Ailamaki, Anastasia Databases H.2.4 Concurrent workloads often extract insights from high-throughput, real-time data streams. Existing stream processing engines isolate each query's resources, ensuring robust performance but incurring high infrastructure costs. In contrast, sharing work reduces the amount of necessary resources but introduces inter-query interference, leading to performance degradation for some queries. We introduce FunShare, a stream-processing system that improves resource efficiency without compromising performance by dynamically grouping queries based on their performance characteristics. FunShare strategically relaxes query interdependencies and minimizes redundant computation while preserving individual query performance. It achieves this by using an adaptive optimization framework that monitors execution metrics, accurately estimates computation overlaps, and reconfigures execution plans on the fly in response to changes in the underlying data streams. Our evaluation demonstrates that FunShare minimizes resource consumption compared to isolated execution while maintaining or improving throughput for all queries. |
| title | Process Faster, Pay Less: Functional Isolation for Stream Processing |
| topic | Databases H.2.4 |
| url | https://arxiv.org/abs/2603.19445 |