Flo: a Semantic Foundation for Progressive Stream Processing
This program is tentative and subject to change.
Streaming systems are present throughout modern applications, enabling real-time processing of continuous data. Existing languages have a variety of semantic models and guarantees that are not composable. Yet all these languages are considered “streaming”—what do they have in common? In this paper, we identify two general yet precise semantic properties: streaming progress and eager execution. Together, they ensure that streaming outputs are deterministic and kept fresh with respect to streaming inputs. We formally define these properties in the context of Flo, a parameterized streaming language that abstracts over dataflow operators and the underlying structure of streams. It leverages a lightweight type system to distinguish bounded streams, which allow operators to block on termination, from unbounded ones. Furthermore, Flo provides constructs for dataflow composition and nested graphs with cycles. To demonstrate the generality of our properties, we show how key ideas from representative streaming and incremental computation systems—Flink, LVars, and DBSP—have semantics that can be modeled in Flo and guarantees that map to our properties.
This program is tentative and subject to change.
Fri 24 JanDisplayed time zone: Mountain Time (US & Canada) change
15:00 - 16:20 | |||
15:00 20mTalk | Flo: a Semantic Foundation for Progressive Stream Processing POPL Shadaj Laddad University of California at Berkeley, Alvin Cheung University of California at Berkeley, Joseph M. Hellerstein UC Berkeley, Mae Milano Princeton University Pre-print | ||
15:20 20mTalk | Top-Down or Bottom-Up? Complexity Analyses of Synchronous Multiparty Session Types POPL | ||
15:40 20mTalk | Semantic Logical Relations for Timed Message-Passing Protocols POPL Yue Yao Carnegie Mellon University, Grant Iraci University at Buffalo, Cheng-En Chuang University at Buffalo, Stephanie Balzer Carnegie Mellon University, Lukasz Ziarek University at Buffalo | ||
16:00 20mTalk | Reachability Analysis of the Domain Name System POPL |