A distributed stream processing framework for stateful computations over unbounded and bounded data streams.