Processing unstructured data streams using continuous queries

A system for continuous processing of unstructured data streams, the system comprising:

• memory for storing information regarding a query, wherein the query is associated with search results and associated statistics derived at an identified time;
• a communication interface for receiving unstructured data from a plurality of streams over a communication network, wherein the unstructured data is received after the identified time;
• and
• a processor for executing instructions stored in memory, wherein execution of the instructions by a processor:
• conducts a full-text search of the received unstructured data based on the query, wherein the conducted search yields one or more matches,
• retrieves the statistics that were derived at the identified time,
• updates the associated statistics based on search results of the unstructured data received at the subsequent time,
• wherein the updated statistics are stored in memory for retrieval at a subsequent time.

A non-transitory computer-readable storage medium, having embodied thereon a program executable by a processor to perform a method for continuous processing of unstructured data streams, the method comprising:

• storing information in memory regarding a query, wherein the query is associated with search results and associated statistics derived at an identified time;
• receiving unstructured data from a plurality of streams over a communication network, wherein the unstructured data is received after the identified time;
• executing instructions stored in memory, wherein execution of the instructions by a processor:
• conducts a full-text search of the received unstructured data based on the query, wherein the conducted search yields one or more matches,
• retrieves the statistics that were derived at the identified time, and
• updates the associated statistics based on search results of the unstructured data received at the subsequent time,
• wherein the updated statistics are stored in memory for retrieval at a subsequent time.