SYSTEM AND A METHOD FOR REASONING AND RUNNING CONTINUOUS QUERIES OVER DATA STREAMS

• US 20150039648A1
• Filed: 04/12/2013
• Published: 02/05/2015
• Est. Priority Date: 04/12/2012
• Status: Active Grant

• Current Assignee: TATA Consultancy Services Limited (Tata Sons Pvt Ltd.)
• Original Assignee: TATA Consultancy Services Limited (Tata Sons Pvt Ltd.)
• Inventors: Mukherjee, Debnath, Misra, Prateep, Banerjee, Snehasis
• Granted Patent: US 9,990,403 B2
• Time in Patent Office: Days
• US Class Current: 707/769
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06N 5/022 Knowledge engineering; Knowledge acquisition
• CPC Class Codes: G06N 5/04 Inference or reasoning models

Abstract

Disclosed is a method and a system for stream reasoning a plurality of data streams. The system comprises a processor and a memory coupled to the processor. The processor is capable of executing a plurality of modules embodied on the memory. The plurality of modules comprises an event module and a application managed window module. The event module is configured to receive a data stream associated with an event from a stream reasoner application. The data stream provides factual information about the event. Further, the data stream comprises a request. The request may be an add request or a delete request. The application managed window module is configured to insert the request associated with the event or delete a prior request associated with the event from the memory based upon a type of the request.

Claims

1. A stream reasoner comprising:

a processor; and

a memory coupled to the processor, wherein the processor is capable of executing instructions stored in the memory, the instructions comprising instructions to;

receive a data stream associated with an event from a client application, wherein the data stream provides factual information about the event, and wherein the data stream comprises a request, and wherein a type of the request is one of an add request and a delete request; and

insert the request associated with the event or delete a prior request associated with the event from the memory based upon the type of the request.

2. The stream reasoner of claim 1, the instructions further comprising instructions to:

configure additional sources for background knowledge corresponding to the data stream, and wherein the background knowledge supplements facts associated with the event.

3. The stream reasoner of claim 2, wherein the additional sources are heterogeneous knowledge sources.

4. The stream reasoner of claim 1, wherein an expiration of the request is dependent on at least one of time, count, and the type of request.

5. The stream reasoner of claim 2, the instructions further comprising instructions to:

provide a reasoning about the event based upon the data stream and the background knowledge corresponding to the data stream.

6. The stream reasoner of claim 5, wherein the reasoning is provided based upon a reasoning technique comprising one or more of a logical reasoning, a deductive reasoning, a rule-based reasoning, an inductive reasoning, and an abductive reasoning.

7. The stream reasoner of claim 5, the instructions further comprising instructions to:

receive query fragments for the reasoning, the data stream, and the background knowledge;

execute the query fragments simultaneously on the reasoning, the data stream, and the background knowledge; and

determine a final result based upon the execution of the query fragments.

8. The stream reasoner of claim 7, the instructions further comprising instructions to:

execute the query fragments in one of a parallel mode and a sequential mode.

9. The stream reasoner of claim 1, wherein the data stream is formatted as a knowledge packet, and wherein each knowledge packet is organized as a set of triples, and wherein each triple comprises a subject, a predicate, and an object.

10. The stream reasoner of claim 5, the instructions further comprising instructions to:

receive a plurality of incremental queries, wherein each incremental query corresponds to a single event; and

execute the plurality of incremental queries on the reasoning, the data stream, and the background knowledge.

11. A method for controlling a request in the stream reasoner, comprising:

receiving a data stream associated with an event from a client application, wherein the data stream provides factual information about the event, and wherein the data stream comprises a request, and wherein a type of the request is one of an add request and a delete request; and

inserting the request associated with the event or deleting a prior request associated with the event from a memory based upon the type of the request.

12. The method of claim 11, further comprising:

configuring additional sources for background knowledge corresponding to the data stream, wherein the background knowledge supplements facts associated with the event.

13. The method of claim 12, wherein the additional sources are heterogeneous knowledge sources.

14. The method of claim 11, wherein an expiration of the request is dependent on at least one of time, count, and the type of request.

15. The method of claim 12, further comprising:

providing a reasoning about the event based upon the data stream and the background knowledge corresponding to the data stream.

16. The method of claim 15, wherein the reasoning is provided based upon a reasoning technique comprising one or more of a logical reasoning, a deductive reasoning, a rule-based reasoning, an abductive reasoning, and an inductive reasoning.

17. The method of claim 16, further comprising:

receiving query fragments for the reasoning, the data stream, and the background knowledge;

executing the query fragments simultaneously on the reasoning, the data stream, and the background knowledge; and

determining a final result based upon summation of the result of the execution of the query fragments.

18. The method of claim 17, wherein the query fragments are executed in one of a parallel mode and a sequential mode.

19. The method of claim 11, wherein the data stream is formatted as a knowledge packet, and wherein each knowledge packet is organized as a set of triples, and wherein each triple comprises a subject, a predicate, and an object.

20. The method of claim 11, further comprising processing the data stream using a combination of a reasoning technique and a plurality of queries, wherein the reasoning technique comprises at least one of a logical reasoning, a deductive reasoning, a rule-based reasoning, an abductive reasoning, and an inductive reasoning.

21. A computer program product having embodied thereon instructions for controlling a request in the stream reasoner, the instructions comprising instructions for:

receiving a data stream associated with an event from a client application, wherein the data stream provides factual information about the event, and wherein the data stream comprises a request, and wherein a type of the request is one of an add request and a delete request; and

adding the request associated with the event or deleting a prior request associated with the event from a memory based upon the type of the request.