Implementation of the stateful functional programming model on top of dataflow execution engine.