Framework for stateful computations over unbounded and bounded data streams.