Event processing finite state engine and language
AssigneeOracle International Corporation
InventorSamuelson Rehman
Life of this patent
Estimating the term…
Abstract
In various embodiments, a method for processing event streams includes receiving a state machine defined in response to a set of processing components, a set of states, and a set of entry points. Event data associated with an event stream is also received. The event data is processed according to the state machine to generate an event.
Claims20
A method for configuring processing engines to process event streams generated by sensors devices, the method comprising:
- receiving, at one or more computer systems, information identifying a set of one or more processing components, each processing component in the set of processing components having a set of inputs and a set of outputs;
- receiving, at the one or more computer systems, information defining a set of one or more states associated with a state machine, each state in the set of states identifying how event data in the events streams generated by the sensor devices that satisfies selection criteria is to be handled by one or more designated processing components in the set of processing components;
- receiving, at the one or more computer systems, information defining a set of entry points into the state machine, each entry point identifying how event data in the event streams generated by the sensors devices that satisfies selection criteria is to be handled by one or more designated processing components in the set of processing components;
- generating, with one or more processors associated with the one or more computer systems, a specification of the state machine according to a metadata-based language that configures a processing engine to process the event streams generated by the sensor devices according to the state machine based on the information identifying the set of one or more processing components, the information defining the set of one or more states associated with the state machine, and the information defining the set of entry points into the state machine;
- and
- storing, in a storage device associated with the one or more computer systems, the specification generated for the state machine.
A non-transitory computer-readable medium storing computer-executable code for configuring processing engines to process event streams generated by sensors devices, the non-transitory computer-readable medium comprising:
- code for receiving information identifying a set of one or more processing components, each processing component in the set of processing components having a set of inputs and a set of outputs;
- code for receiving information defining a set of one or more states associated with a state machine, each state in the set of states identifying how event data in the events streams generated by the sensor devices that satisfies selection criteria is to be handled by one or more designated processing components in the set of processing components;
- code for receiving information defining a set of entry points into the state machine, each entry point identifying how event data in the event streams generated by the sensors devices that satisfies selection criteria is to be handled by one or more designated processing components in the set of processing components;
- code for generating a specification of the state machine according to a metadata-based language that configures a processing engine to process the event streams generated by the sensor devices according to the state machine based on the information identifying the set of one or more processing components, the information defining the set of one or more states associated with the state machine, and the information defining the set of entry points into the state machine;
- and
- code for storing the specification generated for the state machine in a storage device.
An event processing system for processing event streams generated by sensors devices, the event processing system comprising:
- a processor;
- and
- a memory in communication with the processor and configured to store a set of code modules which when executed by the processor cause the processor to:
- receive information identifying a set of one or more processing components, each processing component in the set of processing components having a set of inputs and a set of outputs;
- receive information defining a set of one or more states associated with a state machine, each state in the set of states identifying how event data in the events streams generated by the sensor devices that satisfies selection criteria is to be handled by one or more designated processing components in the set of processing components;
- receive information defining a set of entry points into the state machine, each entry point identifying how event data in the event streams generated by the sensors devices that satisfies selection criteria is to be handled by one or more designated processing components in the set of processing components;
- generate a specification of the state machine according to a metadata-based language that configures a processing engine to process the event streams generated by the sensor devices according to the state machine based on the information identifying the set of one or more processing components, the information defining the set of one or more states associated with the state machine, and the information defining the set of entry points into the state machine;
- and store the specification generated for the state machine in the memory.
Dependencies are inferred from the claim text.