Fri 20 Nov 2020 19:40 - 20:00 at SPLASH-I - F-1A Chair(s): Tongping Liu, Azalea Raad
Real-time data analysis applications increasingly rely on complex streaming computations over time-series data. We propose StreamQL, a language that facilitates the high-level specification of complex analyses over streaming time series. StreamQL is designed as an algebra of stream transformations and provides a collection of combinators for composing them. It integrates three language-based approaches for data stream processing: relational queries, dataflow composition, and temporal formalisms. The relational constructs are useful for specifying simple transformations, aggregations, and the partitioning of data into key-based groups or windows. The dataflow abstractions enable the modular description of a computation as a pipeline of stages or, more generally, as a directed graph of independent tasks. Finally, temporal constructs can be used to specify complex temporal patterns and time-varying computations. These constructs can be composed freely to describe complex streaming computations. We provide a formal denotational semantics for StreamQL using a class of monotone functions over streams. We have implemented StreamQL as a lightweight Java library, which we use to experimentally evaluate our approach. The experiments show that the throughput of our implementation is competitive compared to state-of-the-art streaming engines such as RxJava and Reactor.
Fri 20 NovDisplayed time zone: Central Time (US & Canada) change
07:00 - 08:20 | F-1AOOPSLA at SPLASH-I +12h Chair(s): Diomidis Spinellis Athens University of Economics and Business, John Wickerson Imperial College London | ||
07:00 20mTalk | DiffStream: Differential Output Testing for Stream Processing Programs OOPSLA Konstantinos Kallas University of Pennsylvania, Filip Niksic Google, Caleb Stanford University of Pennsylvania, Rajeev Alur University of Pennsylvania Link to publication DOI Media Attached | ||
07:20 20mTalk | Pomsets with Preconditions: A Simple Model of Relaxed Memory OOPSLA Link to publication DOI Pre-print Media Attached | ||
07:40 20mTalk | StreamQL: A Query Language for Processing Streaming Time Series OOPSLA Link to publication DOI Media Attached | ||
08:00 20mTalk | Foundations of Empirical Memory Consistency Testing OOPSLA Jake Kirkham Princeton University, Tyler Sorensen University of California at Santa Cruz, Esin Tureci Princeton University, Margaret Martonosi Princeton University Link to publication DOI Media Attached |
19:00 - 20:20 | F-1AOOPSLA at SPLASH-I Chair(s): Tongping Liu University of Massachusetts at Amherst, Azalea Raad Imperial College London | ||
19:00 20mTalk | DiffStream: Differential Output Testing for Stream Processing Programs OOPSLA Konstantinos Kallas University of Pennsylvania, Filip Niksic Google, Caleb Stanford University of Pennsylvania, Rajeev Alur University of Pennsylvania Link to publication DOI Media Attached | ||
19:20 20mTalk | Pomsets with Preconditions: A Simple Model of Relaxed Memory OOPSLA Link to publication DOI Pre-print Media Attached | ||
19:40 20mTalk | StreamQL: A Query Language for Processing Streaming Time Series OOPSLA Link to publication DOI Media Attached | ||
20:00 20mTalk | Foundations of Empirical Memory Consistency Testing OOPSLA Jake Kirkham Princeton University, Tyler Sorensen University of California at Santa Cruz, Esin Tureci Princeton University, Margaret Martonosi Princeton University Link to publication DOI Media Attached |