Simple date flooring, floor a date to the start of a specified time window.
Aggregation operations for timeseries streams (objectMode streams ordered by timestamp)
Tool for dealing with logs as a stream of events for analysis
Aggragation util for timestamps