×

Analytical data processing engine

  • US 9,697,262 B2
  • Filed: 12/17/2013
  • Issued: 07/04/2017
  • Est. Priority Date: 12/17/2013
  • Status: Active Grant
First Claim
Patent Images

1. A method comprising:

  • under control of one or more computing devices;

    receiving a real-time or near real-time query for a stream of incoming data events;

    annotating each individual data event of the incoming data events with a first timestamp and a second timestamp, wherein;

    the first timestamp identifies when the individual data event is received; and

    the second timestamp identifies additional information associated with the individual data event;

    organizing the stream of the incoming data events into a sequence of data batches based at least in part on the first timestamp of each individual data event of the incoming data events, wherein individual data batches, of the sequence of data batches, include multiple data events; and

    processing the individual data batches of the sequence of data batches in a non-decreasing time order, wherein each individual data batch stores;

    a key array that includes an array of grouping key values, the grouping key values representing a logic group of a data event, andcontrol parameters that include;

    a synctime array that includes synctime values of at least some events in an individual data batch, andan othertime array that includes othertime values that indicate known future times that individual ones of the events in the individual data batch are expected to end;

    based on at least one of the key array, the synctime array, and the othertime array, presenting a result comprising one or more values from the stream of incoming data events in response to the received real-time or near real-time query.

View all claims
  • 2 Assignments
Timeline View
Assignment View
    ×
    ×