Greetings! I am a computer scientist and engineer working at Google, and a founding committer to the incubating Apache Beam project, providing a common programming model for batch and streaming dataflow DAG-based big data computations.

Do you love mathematics, design, code, and big data like I do? Here are highlights of my work on Beam:

Apache Beam (incubating) Pipeline Runner API
What is a Beam pipeline? What are the primitive transformations? What are the user-defined functions? What is a Beam pipeline runner?

This document lays out the definition of the Beam programming model, along with technical details of cross-runner support implemented in the Beam.

Lateness (and Panes) in Apache Beam (incubating)
In a streaming computation, where data comes in telling you about events that happened somewhere in the world, what does it mean for data to be "late"? How should we manage computations over such data?

This document explores the concept of lateness and lays out the mathematical description along with guidelines that steer the implementation of Beam.

I also had a life before all that. You may also enjoy my other quasi-pedagogical writings on mathematics, computer science, and technology.

Functional Lens
Casual essays (most of which are executable) about mathematics, computation, and functional programming.
Code // Comment
Tutorials (most of which are executable) about current programing technology.