Adding support for temporal queries in aggregates data stream