Communication-efficient processing of multiple continuous aggregate queries

Cited 1 time in webofscience Cited 0 time in scopus
  • Hit : 439
  • Download : 0
DC FieldValueLanguage
dc.contributor.authorJeon, Joo Hyukko
dc.contributor.authorLee, Ki Yongko
dc.contributor.authorKim, Myoung Hoko
dc.date.accessioned2014-11-12T07:18:57Z-
dc.date.available2014-11-12T07:18:57Z-
dc.date.created2014-07-16-
dc.date.created2014-07-16-
dc.date.issued2014-11-
dc.identifier.citationINFORMATION SCIENCES, v.284, no.Special SI, pp.1 - 17-
dc.identifier.issn0020-0255-
dc.identifier.urihttp://hdl.handle.net/10203/191075-
dc.description.abstractRecently, great attention has been paid to distributed stream processing systems (DSPSs), where a number of distributed source nodes generate data streams and queries are continuously executed over those streams. An emerging challenge in large-scale DSPSs is to efficiently process multiple continuous aggregate queries. To process a continuous aggregate query, each source node periodically sends partial aggregates computed over its local stream to the sink node, where the final results are computed. Since sending partial aggregates for each query separately can lead to significant communication overhead, lowering the overall performance and scalability, multiple aggregate queries must be processed collectively, rather than separately. In this paper, we propose an efficient method for collectively processing multiple continuous aggregate queries, which minimizes the total communication costs from source nodes to the sink node. The proposed method finds the smallest set of partial aggregates that each source node needs to send to the sink node to correctly answer all the queries, and thus minimizes the number of message transmissions. Furthermore, since the proposed method operates on-the-fly, it can efficiently handle registration or deregistration of queries at any time. Through theoretical analysis and experiments, we show that the proposed method outperforms the existing ones in terms of communication costs.-
dc.languageEnglish-
dc.publisherELSEVIER SCIENCE INC-
dc.titleCommunication-efficient processing of multiple continuous aggregate queries-
dc.typeArticle-
dc.identifier.wosid000341677100001-
dc.identifier.scopusid2-s2.0-84906686306-
dc.type.rimsART-
dc.citation.volume284-
dc.citation.issueSpecial SI-
dc.citation.beginningpage1-
dc.citation.endingpage17-
dc.citation.publicationnameINFORMATION SCIENCES-
dc.identifier.doi10.1016/j.ins.2014.06.044-
dc.contributor.localauthorKim, Myoung Ho-
dc.contributor.nonIdAuthorLee, Ki Yong-
dc.type.journalArticleArticle-
dc.subject.keywordAuthorAggregate query-
dc.subject.keywordAuthorMulti-query optimization-
dc.subject.keywordAuthorDistributed data stream-
dc.subject.keywordAuthorSliding window-
Appears in Collection
CS-Journal Papers(저널논문)
Files in This Item
There are no files associated with this item.
This item is cited by other documents in WoS
⊙ Detail Information in WoSⓡ Click to see webofscience_button
⊙ Cited 1 items in WoS Click to see citing articles in records_button

qr_code

  • mendeley

    citeulike


rss_1.0 rss_2.0 atom_1.0