Method and system for querying streaming data
AssigneeYahoo Holdings, Inc.
InventorsAkshai Sarma, Michael Natkovich
Life of this patent
Estimating the term…
Abstract
The present teaching relates to streaming data querying and providing query results. In one example, a query is received for events happening after receipt of the query. A plurality of data records are obtained, where each of the data records corresponds to an event happening after receipt of the query. For each of the plurality of data records, it is determined whether the data record matches the query. Based on the determining, one or more query results are determined and provided as a response to the query.
Claims20
A method, implemented on a machine having at least one processor, storage, and a communication platform connected to a network for providing query results, the method comprising:
- receiving a query for events happening after receipt of the query;
- obtaining a plurality of data records each of which corresponds to an event happening after receipt of the query;
- determining, for each of the plurality of data records, whether the data record matches the query;
- generating, based on the determining, one or more query results;
- and
- providing the one or more query results as a response to the query.
A method, implemented on a machine having at least one processor, storage, and a communication platform connected to a network for providing query results, the method comprising:
- receiving, within a predetermined time period, a plurality of queries, wherein each of the plurality of queries is submitted for querying events happening after receipt of the query;
- obtaining a plurality of data records each of which corresponds to an event happening after receipt of the plurality of queries;
- determining, for each of the plurality of data records, whether the data record matches any of the plurality of queries;
- generating, based on the determining, one or more query results for each of the plurality of queries;
- and
- providing the one or more query results as a response to a corresponding query in the plurality of queries.
A system having at least one processor, storage, and a communication platform connected to a network for providing query results, comprising:
- a request processor configured for receiving a query for events happening after receipt of the query;
- a streaming data standardizer configured for obtaining a plurality of data records each of which corresponds to an event happening after receipt of the query;
- a streaming data sub-processor configured for determining, for each of the plurality of data records, whether the data record matches the query;
- and
- a query result generator configured for generating, based on the determining, one or more query results, and providing the one or more query results as a response to the query.
A system having at least one processor, storage, and a communication platform connected to a network for providing query results, comprising:
- a request processor configured for receiving, within a predetermined time period, a plurality of queries, wherein each of the plurality of queries is submitted for querying events happening after receipt of the query;
- a streaming data standardizer configured for obtaining a plurality of data records each of which corresponds to an event happening after receipt of the plurality of queries;
- a plurality of streaming data sub-processors configured for determining, for each of the plurality of data records, whether the data record matches any of the plurality of queries;
- and
- a plurality of query result combiners configured for generating, based on the determining, one or more query results for each of the plurality of queries, and providing the one or more query results as a response to a corresponding query in the plurality of queries.
A non-transitory machine-readable medium having information recorded thereon for providing query results, wherein the information, when read by the machine, causes the machine to perform the following:
- receiving a query for events happening after receipt of the query;
- obtaining a plurality of data records each of which corresponds to an event happening after receipt of the query;
- determining, for each of the plurality of data records, whether the data record matches the query;
- generating, based on the determining, one or more query results;
- and
- providing the one or more query results as a response to the query.
A non-transitory machine-readable medium having information recorded thereon for providing query results, wherein the information, when read by the machine, causes the machine to perform the following:
- receiving, within a predetermined time period, a plurality of queries, wherein each of the plurality of queries is submitted for querying events happening after receipt of the query;
- obtaining a plurality of data records each of which corresponds to an event happening after receipt of the plurality of queries;
- determining, for each of the plurality of data records, whether the data record matches any of the plurality of queries;
- generating, based on the determining, one or more query results for each of the plurality of queries;
- and
- providing the one or more query results as a response to a corresponding query in the plurality of queries.
Dependencies are inferred from the claim text.