About Time: An Introduction to Timely Dataflow [talk]
This is a conference talk Malte and Niko gave at Data Council Barcelona 2019.
kplex - Decoupling Partitioning in Kafka
We discuss partitioning — arguably the highest impact decision in any Kafka setup — and introduce kplex, a tool for repartitioning Kafka topics consistently and on-the-fly, allowing you to unlock concurrency and perform correct stateful processing across partitions.
Incremental Functional Aggregate Queries
This blog post concludes a research project I’ve done together with Frank McSherry earlier this year at ETH Zurich.
Reaktive Queries über verteilte Data Streams [Talk]
Diesen Talk haben David und Moritz auf der Konferenz buildingIoT 2019 in Kooperation mit Frank McSherry, Malte und Niko gehalten.
A Many-Worlds Interpretation of State [talk]
This is a conference talk Malte and Niko gave at BobKonf 2019.
3DF: Reactive Datalog for Datomic [talk]
This is a conference talk Niko gave in cooperation with Frank McSherry, David, and Malte at ClojureD 2019.
Dataflows you can't refuse
In this article, we’ll explore what bringing a declarative, pull-based web after tomorrow to life actually means.
Reactive Datalog for Datomic [talk]
This is a conference talk Niko gave in cooperation with Frank McSherry, David, and Malte at Clojure/conj 2018.
Reactive Datalog with Vega
In this post we will build a streaming Vega visualization backed by reactive Datalog queries.
Incremental Datalog with Differential Dataflows
We propose a method of continuously executing Datalog queries over data streams, by compiling them to differential dataflows. This work originated at ETH Zurich’s Systems group, in collaboration with Frank McSherry and Prof. Gustavo Alonso.