Windowed query with event-based open time for analytics of streaming data

A computer-implemented method, comprising:

• causing presentation of a user interface via a display of a customer device;
• receiving, via the user interface, customer input comprising one or more parameters defining a windowed query, wherein the one or more parameters include at least a destination location to receive query results and an incoming data stream of a plurality of incoming data streams;
• creating, based at least in part on the customer input, an analytics application configured to process the incoming data stream by executing the windowed query against the incoming data stream;
• detecting, by the analytics application, a receipt, by the windowed query, of a first stream event associated with a grouping key, the first stream event corresponding to first data of an incoming data stream that is being processed by the analytics application using the windowed query;
• responsive to the receipt of the first stream event, collecting, by the analytics application, query data for a predefined duration specified in the windowed query, the predefined duration starting at a time when the first stream event is received by the windowed query, the query data based at least in part on the first stream event and any additional stream events associated with the grouping key that are received before a lapse of the predefined duration;
• and
• based at least in part on the query data, sending, by the analytics application and to the destination location, the query results in association with a window of the windowed query.

One or more non-transitory computer-readable media storing computer-executable instructions that, when executed by one or more processors of a network-based analytics system, cause the network-based analytics system to:

• cause presentation of a user interface via a display associated with a customer device;
• receive, via the user interface, customer input comprising one or more parameters defining a windowed query, wherein the one or more parameters include at least a destination location to receive query results and an incoming data stream of a plurality of incoming data streams;
• open a window of the windowed query at a time when a first stream event associated with a grouping key of the window is received by the windowed query, the first stream event corresponding to first data of the incoming data stream;
• generate query results based at least in part on the first stream event and any additional stream events associated with the grouping key that are received while the window remains open;
• close the window upon a lapse of a predefined duration specified in the windowed query;
• and
• send the query results to the destination location.