Validate a Data-Processing Transformation

Problem

Given streaming records, group/aggregate by a key and emit running totals.

Example

records of (category, amount) -> running sum per category

Constraints

• Stream may be large; bounded memory

Discussion

Discuss correctness on out-of-order or malformed records.