{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,3,19]],"date-time":"2026-03-19T02:16:10Z","timestamp":1773886570354,"version":"3.50.1"},"reference-count":40,"publisher":"Association for Computing Machinery (ACM)","issue":"10","content-domain":{"domain":[],"crossmark-restriction":false},"short-container-title":["Proc. VLDB Endow."],"published-print":{"date-parts":[[2020,6]]},"abstract":"<jats:p>Current systems for data-parallel, incremental processing and view maintenance over high-rate streams isolate the execution of independent queries. This creates unwanted redundancy and overhead in the presence of concurrent incrementally maintained queries: each query must independently maintain the same indexed state over the same input streams, and new queries must build this state from scratch before they can begin to emit their first results.<\/jats:p>\n          <jats:p>\n            This paper introduces\n            <jats:italic>shared arrangements<\/jats:italic>\n            : indexed views of maintained state that allow concurrent queries to reuse the same in-memory state without compromising data-parallel performance and scaling. We implement shared arrangements in a modern stream processor and show order-of-magnitude improvements in query response time and resource consumption for incremental, interactive queries against high-throughput streams, while also significantly improving performance in other domains including business analytics, graph processing, and program analysis.\n          <\/jats:p>","DOI":"10.14778\/3401960.3401974","type":"journal-article","created":{"date-parts":[[2021,3,10]],"date-time":"2021-03-10T19:15:14Z","timestamp":1615403714000},"page":"1793-1806","source":"Crossref","is-referenced-by-count":15,"title":["Shared arrangements"],"prefix":"10.14778","volume":"13","author":[{"given":"Frank","family":"McSherry","sequence":"first","affiliation":[{"name":"Materialize, Inc."}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Andrea","family":"Lattuada","sequence":"additional","affiliation":[{"name":"ETH Z\u00fcrich"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Malte","family":"Schwarzkopf","sequence":"additional","affiliation":[{"name":"Brown University"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Timothy","family":"Roscoe","sequence":"additional","affiliation":[{"name":"ETH Z\u00fcrich"}],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"320","published-online":{"date-parts":[[2021,3,10]]},"reference":[{"key":"e_1_2_1_1_1","unstructured":"https:\/\/github.com\/TimelyDataflow\/differential-dataflow\/.  https:\/\/github.com\/TimelyDataflow\/differential-dataflow\/."},{"key":"e_1_2_1_2_1","unstructured":"https:\/\/github.com\/TimelyDataflow\/timely-dataflow\/.  https:\/\/github.com\/TimelyDataflow\/timely-dataflow\/."},{"key":"e_1_2_1_3_1","unstructured":"DDlog. https:\/\/research.vmware.com\/projects\/differential-datalog-ddlog.  DDlog. https:\/\/research.vmware.com\/projects\/differential-datalog-ddlog."},{"key":"e_1_2_1_4_1","unstructured":"DLVSYSTEM. http:\/\/www.dlvsystem.com.  DLVSYSTEM. http:\/\/www.dlvsystem.com."},{"key":"e_1_2_1_5_1","unstructured":"Jemalloc memory allocator. http:\/\/jemalloc.net.  Jemalloc memory allocator. http:\/\/jemalloc.net."},{"key":"e_1_2_1_6_1","unstructured":"The TPC-H decision support benchmark. http:\/\/www.tpc.org\/tpch\/default5.asp.  The TPC-H decision support benchmark. http:\/\/www.tpc.org\/tpch\/default5.asp."},{"key":"e_1_2_1_7_1","doi-asserted-by":"publisher","DOI":"10.1007\/978-3-662-46678-0_5"},{"key":"e_1_2_1_8_1","doi-asserted-by":"publisher","DOI":"10.14778\/2336664.2336670"},{"key":"e_1_2_1_9_1","doi-asserted-by":"crossref","first-page":"317","DOI":"10.1007\/978-3-540-28608-0_16","volume-title":"STREAM: The Stanford Data Stream Management System","author":"Arasu A.","year":"2016"},{"key":"e_1_2_1_10_1","doi-asserted-by":"publisher","DOI":"10.1145\/6012.15399"},{"key":"e_1_2_1_11_1","doi-asserted-by":"publisher","DOI":"10.14778\/1687627.1687659"},{"key":"e_1_2_1_12_1","volume-title":"Apache flink: Stream and batch processing in a single engine","author":"Carbone P.","year":"2015"},{"key":"e_1_2_1_13_1","doi-asserted-by":"publisher","DOI":"10.1145\/872757.872857"},{"key":"e_1_2_1_14_1","doi-asserted-by":"publisher","DOI":"10.1145\/342009.335432"},{"key":"e_1_2_1_15_1","volume-title":"Sept.","author":"Darling E.","year":"2019"},{"key":"e_1_2_1_16_1","doi-asserted-by":"publisher","DOI":"10.1145\/1327452.1327492"},{"key":"e_1_2_1_17_1","doi-asserted-by":"publisher","DOI":"10.14778\/3311880.3311886"},{"key":"e_1_2_1_18_1","doi-asserted-by":"publisher","DOI":"10.14778\/2168651.2168654"},{"key":"e_1_2_1_19_1","doi-asserted-by":"publisher","DOI":"10.5555\/3291168.3291185"},{"key":"e_1_2_1_20_1","doi-asserted-by":"publisher","DOI":"10.5555\/2831090.2831092"},{"key":"e_1_2_1_21_1","doi-asserted-by":"publisher","DOI":"10.5555\/2685048.2685096"},{"key":"e_1_2_1_22_1","doi-asserted-by":"publisher","DOI":"10.1145\/3299869.3324959"},{"key":"e_1_2_1_23_1","doi-asserted-by":"publisher","DOI":"10.5555\/1924943.1924949"},{"key":"e_1_2_1_24_1","doi-asserted-by":"publisher","DOI":"10.1145\/1272998.1273005"},{"key":"e_1_2_1_25_1","doi-asserted-by":"publisher","DOI":"10.1145\/3299869.3319884"},{"key":"e_1_2_1_26_1","unstructured":"F. McSherry A. Lattuada M. Schwarzkopf and T. Roscoe. Shared arrangements: Practical inter-query sharing for streaming dataflows (extended technical report). https:\/\/arxiv.org\/abs\/1812.02639.  F. McSherry A. Lattuada M. Schwarzkopf and T. Roscoe. Shared arrangements: Practical inter-query sharing for streaming dataflows (extended technical report). https:\/\/arxiv.org\/abs\/1812.02639."},{"key":"e_1_2_1_27_1","volume-title":"Proceedings of the 6th Biennial Conference on Innovative Data Systems Research (CIDR)","author":"McSherry F.","year":"2013"},{"key":"e_1_2_1_28_1","doi-asserted-by":"publisher","DOI":"10.1145\/2517349.2522738"},{"key":"e_1_2_1_29_1","doi-asserted-by":"publisher","DOI":"10.1145\/2882903.2915246"},{"key":"e_1_2_1_30_1","doi-asserted-by":"publisher","DOI":"10.1145\/3078447.3078459"},{"key":"e_1_2_1_31_1","volume-title":"April","author":"PostgreSQL Global Development Group","year":"2019"},{"key":"e_1_2_1_32_1","doi-asserted-by":"publisher","DOI":"10.1109\/TKDE.2015.2405562"},{"key":"e_1_2_1_33_1","doi-asserted-by":"publisher","DOI":"10.1145\/2882903.2915229"},{"key":"e_1_2_1_34_1","volume-title":"Transaction repair: Full serializability without locks. https:\/\/arxiv.org\/abs\/1403.5645","author":"Veldhuizen T. L.","year":"2014"},{"key":"e_1_2_1_35_1","volume-title":"Proceedings of the 8th Biennial Conference on Innovative Data Systems Research (CIDR)","author":"Wang J.","year":"2017"},{"key":"e_1_2_1_36_1","doi-asserted-by":"publisher","DOI":"10.1145\/3093337.3037744"},{"key":"e_1_2_1_37_1","doi-asserted-by":"publisher","DOI":"10.1007\/s00778-016-0448-z"},{"key":"e_1_2_1_38_1","doi-asserted-by":"publisher","DOI":"10.5555\/1855741.1855742"},{"key":"e_1_2_1_39_1","doi-asserted-by":"publisher","DOI":"10.5555\/2228298.2228301"},{"key":"e_1_2_1_40_1","doi-asserted-by":"publisher","DOI":"10.1145\/2517349.2522737"}],"container-title":["Proceedings of the VLDB Endowment"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.14778\/3401960.3401974","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2022,12,28]],"date-time":"2022-12-28T11:12:23Z","timestamp":1672225943000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.14778\/3401960.3401974"}},"subtitle":["practical inter-query sharing for streaming dataflows"],"short-title":[],"issued":{"date-parts":[[2020,6]]},"references-count":40,"journal-issue":{"issue":"10","published-print":{"date-parts":[[2020,6]]}},"alternative-id":["10.14778\/3401960.3401974"],"URL":"https:\/\/doi.org\/10.14778\/3401960.3401974","relation":{},"ISSN":["2150-8097"],"issn-type":[{"value":"2150-8097","type":"print"}],"subject":[],"published":{"date-parts":[[2020,6]]}}}