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