System and method for supporting a testing framework for an event processing system using multiple input event streams
First Claim
1. A method for testing an event stream processing system with a testing framework, the testing framework operating on one or more processors and operably connected to the event processing system, the method comprising:
- declaring input event data, expected output event data, and at least one processing rule for a test in an XML file, wherein the XML file is associated with an XML schema for testing the event processing system;
reading in, by the testing framework, and into a memory accessible by the testing framework, the input event data, output event data, and the processing rule;
sending, by the testing framework, a plurality of input events in multiple event streams to the event stream processing system, wherein each said input event is associated with a timestamp;
prescribing, by the testing framework, one or more expected output events that correspond to said plurality of input events in multiple event streams, wherein each said expected output event is associated with a timestamp; and
using, by the testing framework, said one or more expected output events to verify one or more actual output events that are received from the event processing system, wherein each said actual output event is associated with a timestamp.
1 Assignment
0 Petitions
Accused Products
Abstract
Systems and methods can use a testing framework for testing an event processing system. The testing framework operates to send a plurality of input events in multiple event streams to an event processing system, wherein each said input event is associated with a timestamp. Also, the testing framework prescribes one or more expected output events that correspond to said plurality of input events in multiple event streams, wherein each said expected output event is associated with a timestamp. Furthermore, the testing framework can use said one or more expected output events to verify one or more actual output events that are received from the event processing system, wherein each said actual output event is associated with a timestamp.
-
Citations
27 Claims
-
1. A method for testing an event stream processing system with a testing framework, the testing framework operating on one or more processors and operably connected to the event processing system, the method comprising:
-
declaring input event data, expected output event data, and at least one processing rule for a test in an XML file, wherein the XML file is associated with an XML schema for testing the event processing system; reading in, by the testing framework, and into a memory accessible by the testing framework, the input event data, output event data, and the processing rule; sending, by the testing framework, a plurality of input events in multiple event streams to the event stream processing system, wherein each said input event is associated with a timestamp; prescribing, by the testing framework, one or more expected output events that correspond to said plurality of input events in multiple event streams, wherein each said expected output event is associated with a timestamp; and using, by the testing framework, said one or more expected output events to verify one or more actual output events that are received from the event processing system, wherein each said actual output event is associated with a timestamp. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A system for testing an event stream processing system, comprising:
-
one or more microprocessors; a testing framework, running on the one or more microprocessors and operably connected to the event stream processing system, wherein the testing framework operates to; declare input event data, expected output event data, and at least one processing rule for a test in an XML file, wherein the XML file is associated with an XML schema for testing the event processing system; read, into a memory accessible by the testing framework, the input event data, output event data, and the processing rule; send a plurality of input events in multiple event streams to the event stream processing system, wherein each said input event is associated with a timestamp; prescribe one or more expected output events that correspond to said plurality of input events in multiple event streams, wherein each said expected output event is associated with a timestamp; and use said one or more expected output events to verify one or more actual output events that are received from the event processing system, wherein each said actual output event is associated with a timestamp. - View Dependent Claims (12, 13, 14, 15, 16, 17, 18, 19)
-
-
20. A non-transitory machine readable storage medium having instructions stored thereon that when executed by one or more processors cause a testing framework that is operably connected to an event stream processing system to perform the steps comprising:
-
declaring input event data, expected output event data data, and at least one processing rule for a test in an XML file, wherein the XML file is associated with an XML schema for testing the event processing system; reading into a memory accessible by the testing framework, the input event data, output event data, and the processing rule; sending a plurality of input events in multiple event streams to the event stream processing system, wherein each said input event is associated with a timestamp; prescribing one or more expected output events that correspond to said plurality of input events in multiple event streams, wherein each said expected output event is associated with a timestamp; and using said one or more expected output events to verify one or more actual output events that are received from the event processing system, wherein each said actual output event is associated with a timestamp.
-
-
21. A method for testing an event stream processing system with a testing framework, the testing framework operating on one or more processors and operably connected to the event processing system, the method comprising:
-
reading in, by the testing framework, and into a memory accessible by the testing framework, input events data, expected output events data, and a processing rule; converting, by the testing framework, the input events data into a plurality of input event objects; configuring multiple event streams to the event stream processing system, each of the multiple event streams having separate corresponding connections, event channels, and threads; sending the plurality of input event objects in the multiple event streams to the event stream processing system, wherein each said input event object is associated with a timestamp; prescribing one or more expected output events that correspond to said plurality of input event objects in each of the multiple event streams, wherein each said expected output event is associated with a timestamp; receiving, by the testing framework and from the event stream processing system, an actual output event, wherein the actual output event is associated with a timestamp; and using said one or more expected output events to verify the actual output event. - View Dependent Claims (22, 23, 24, 25)
-
-
26. A method for testing an event stream processing system with a testing framework, the testing framework operating on one or more processors and operably connected to the event stream processing system, the method comprising:
-
reading in, by a testing framework, input events data, output events data, and a processing rule; converting, by the testing framework, the input events data into a plurality of input event objects; sending the plurality of input event objects in multiple event streams to the event stream processing system, wherein each said input event object is associated with a timestamp; applying a plurality of event windows on the multiple event streams, wherein each event stream of the multiple event streams is applied with one event window of the plurality of event windows, and wherein the plurality of event windows applied on the multiple event streams share a common base time; prescribing one or more expected output events that correspond to said plurality of input event objects in each of the multiple event streams, wherein each said expected output event is associated with a timestamp; and receiving, by the testing framework and from the event stream processing system, an actual output event, wherein the actual output event is associated with a timestamp; using said one or more expected output events to verify the actual output event ; and using the common base time, when a first assert statement is processed, as a base time for an application timestamped event stream in a test.
-
-
27. A method for testing an event stream processing system with a testing framework, the testing framework operating on one or more processors and operably connected to the event stream processing system, the method comprising:
-
reading in, by a testing framework, input events data, output events data, and a processing rule; converting, by the testing framework, the input events data into a plurality of input event objects; sending the plurality of input event objects in multiple event streams to an event processing system, wherein each said input event object is associated with a timestamp; applying a plurality of event windows on the multiple event streams, wherein each event stream of the multiple event streams is applied with one event window of the plurality of event windows, and wherein the plurality of event windows applied on the multiple event streams share a common base time; prescribing one or more expected output events that correspond to said plurality of input event objects in each of the multiple event streams, wherein each said expected output event is associated with a timestamp; and receiving, by the testing framework and from the event processing system, an actual output event, wherein the actual output event is associated with a timestamp; and using said one or more expected output events to verify the actual output event; and using the common base time, when a first assert statement is processed and after a corresponding sliding point is obtained, as a base time for a system timestamped event stream in a test.
-
Specification