A Holistic View of Stream Partitioning Costs. Katsipoulakis, N., R.; Labrinidis, A.; and Chrysanthis, P., K.
A Holistic View of Stream Partitioning Costs [pdf]Paper  abstract   bibtex   
Stream processing has become the dominant processing model for monitoring and real-time analytics. Modern Parallel Stream Pro-cessing Engines (pSPEs) have made it feasible to increase the per-formance in both monitoring and analytical queries by parallelizing a query's execution and distributing the load on multiple workers. A determining factor for the performance of a pSPE is the parti-tioning algorithm used to disseminate tuples to workers. Until now, partitioning methods in pSPEs have been similar to the ones used in parallel databases and only recently load-aware algorithms have been employed to improve the effectiveness of parallel execution. We identify and demonstrate the need to incorporate aggregation costs in the partitioning model when executing stateful operations in parallel, in order to minimize the overall latency and/or through-put. Towards this, we propose new stream partitioning algorithms, that consider both tuple imbalance and aggregation cost. We eval-uate our proposed algorithms and show that they can achieve up to an order of magnitude better performance, compared to the current state of the art.
@article{
 title = {A Holistic View of Stream Partitioning Costs},
 type = {article},
 pages = {1286-1297},
 id = {4d2f96d3-8f93-35a1-82be-c33e7fa724bf},
 created = {2017-08-29T16:55:16.279Z},
 file_attached = {true},
 profile_id = {9d42c173-db8a-3566-8a55-b1a79270b5ed},
 group_id = {325c0157-5788-3a71-bd59-340f23437b88},
 last_modified = {2018-01-10T17:12:35.379Z},
 read = {false},
 starred = {false},
 authored = {false},
 confirmed = {true},
 hidden = {false},
 citation_key = {Katsipoulakis},
 private_publication = {false},
 abstract = {Stream processing has become the dominant processing model for monitoring and real-time analytics. Modern Parallel Stream Pro-cessing Engines (pSPEs) have made it feasible to increase the per-formance in both monitoring and analytical queries by parallelizing a query's execution and distributing the load on multiple workers. A determining factor for the performance of a pSPE is the parti-tioning algorithm used to disseminate tuples to workers. Until now, partitioning methods in pSPEs have been similar to the ones used in parallel databases and only recently load-aware algorithms have been employed to improve the effectiveness of parallel execution. We identify and demonstrate the need to incorporate aggregation costs in the partitioning model when executing stateful operations in parallel, in order to minimize the overall latency and/or through-put. Towards this, we propose new stream partitioning algorithms, that consider both tuple imbalance and aggregation cost. We eval-uate our proposed algorithms and show that they can achieve up to an order of magnitude better performance, compared to the current state of the art.},
 bibtype = {article},
 author = {Katsipoulakis, Nikos R and Labrinidis, Alexandros and Chrysanthis, Panos K}
}
Downloads: 0