SOLE: Scalable on-line execution of continuous queries on spatio-temporal data streams

Mohamed F. Mokbel, Walid G. Aref

Research output: Contribution to journalArticlepeer-review

78 Scopus citations

Abstract

This paper presents the scalable on-line execution (SOLE) algorithm for continuous and on-line evaluation of concurrent continuous spatio-temporal queries over data streams. Incoming spatio-temporal data streams are processed in-memory against a set of outstanding continuous queries. The SOLE algorithm utilizes the scarce memory resource efficiently by keeping track of only the significant objects. In-memory stored objects are expired (i.e., dropped) from memory once they become insignificant. SOLE is a scalable algorithm where all the continuous outstanding queries share the same buffer pool. In addition, SOLE is presented as a spatio-temporal join between two input streams, a stream of spatio-temporal objects and a stream of spatio-temporal queries. To cope with intervals of high arrival rates of objects and/or queries, SOLE utilizes a load-shedding approach where some of the stored objects are dropped from memory. SOLE is implemented as a pipelined query operator that can be combined with traditional query operators in a query execution plan to support a wide variety of continuous queries. Performance experiments based on a real implementation of SOLE inside a prototype of a data stream management system show the scalability and efficiency of SOLE in highly dynamic environments.

Original languageEnglish (US)
Pages (from-to)971-995
Number of pages25
JournalVLDB Journal
Volume17
Issue number5
DOIs
StatePublished - Aug 2008

Fingerprint Dive into the research topics of 'SOLE: Scalable on-line execution of continuous queries on spatio-temporal data streams'. Together they form a unique fingerprint.

Cite this