Aggregation based on Stream data