Patent application number | Description | Published |
20090327476 | Dynamic Infrastructure for Monitoring Service Level Agreements - A dynamic infrastructure for monitoring service level agreements (SLAs) is described. In an embodiment, the infrastructure comprises three types of functional elements: probes, metrics and audits and a small number of primitive actions for manipulating these elements. The elements are connected by streams which store data for processing and transport data between functional elements. The primitive actions, which are duplicating and removing functional elements as well as splitting and joining metrics, are arranged such that the functional elements can be optimized dynamically in responses to changes in the service and/or the hardware without losing any data. | 12-31-2009 |
20100287361 | Root Cause Analysis for Complex Event Processing - Root cause analysis for complex event processing is described. In embodiments, root cause analysis at a complex event processor is automatically performed by selecting an output event from an operator and correlating the output event to an input event using event type and lifetime data for the input event and the output event stored in a data store. Embodiments describe how the lifetime data can comprise a start time and an end time for the event, and the correlation can be based on a comparison of the start and end times between the input and output events. Embodiments describe how the correlation algorithm used is selected in dependence on the event type. In embodiments, a complex event processing engine comprises a logging unit arranged to store in the data store an indicator of an event type and lifetime data for each output event from an operator. | 11-11-2010 |
20110283144 | ANALYSIS STACK FOR COMPLEX EVENT FLOWS - Methods, systems, and computer-readable media to analyze a CEP query are disclosed. A particular analysis module is configured to receive data associated with an event flow generated by execution of a CEP query. The data is received from a first analysis module (e.g., in a stack of analysis modules) or from the event flow via a software communication interface. The analysis module is also configured to execute an analysis operation on the data to generate a result. The analysis module can output the result to a second analysis module (e.g., in the stack of analysis modules) or to a user interface via the software communication interface. | 11-17-2011 |
20110283239 | VISUAL ANALYSIS AND DEBUGGING OF COMPLEX EVENT FLOWS - Methods, systems, and computer-readable media to generate a user interface (UI) to analyze a complex event processing (CEP) query are disclosed. A particular method includes receiving data representing an event flow associated with execution of a CEP query. The CEP query includes a plurality of operators. A UI including a graph is generated. The graph includes a plurality of nodes. Each node of the graph corresponds to an operator of the CEP query, and each edge of the graph corresponds to a stream between operators of the CEP query. The method includes receiving an input identifying a particular node of the graph, where the particular node corresponds to a particular operator of the CEP query. In response to the input, an operator-specific output associated with at least one event processed by the particular operator is displayed. | 11-17-2011 |
20130031567 | LOCAL EVENT PROCESSING - The claimed subject matter provides a method for processing a stream of events. The method includes receiving a stream of events at a local device. The stream of events is associated with the local device. Further, the stream of events includes one or more out-of-order events. The method also includes executing a first complex event processing query against the stream of events. The stream of events is processed based on multiple levels of consistency defined by a set of operators. Additionally, the method includes correcting the out-of-order events based on the set of operators. A first output is generated in which consistency is guaranteed based on the corrected out-of-order events. The method also includes sending the first output to a server that performs complex event processing on the output. | 01-31-2013 |
20130262645 | MANAGING DISTRIBUTED ANALYTICS ON DEVICE GROUPS - Methods of managing distributed analytics on device groups are described. In an embodiment, a management service within a distributed analytics system provides an interface to allow a user to define a group of devices based on a property of the devices. When the property of a device in the system satisfies the criterion specified by the user, the device is added to the group and the device may subsequently be removed from the group if the device no longer satisfies the criterion. Once a group has been defined, the management service enables users to specify management operations, such as creating, starting, stopping or deleting queries or management operations relating to other entities of end devices, which are to be implemented on all the devices in the group and the management service propagates the operation to all devices in the group, irrespective of their current connectivity status. | 10-03-2013 |
20140195465 | MONITOR-MINE-MANAGE CYCLE - A monitor-mine-manage cycle is described, for example, for managing a data center, a manufacturing process, an engineering process or other processes. In various example, the following steps are performed as a continuous automated loop: receiving raw events from an observed system; monitoring the raw events and transforming them into complex events; mining the complex events and reasoning on results; making a set of proposed actions based on the mining; and managing the observed system by applying one or more of the proposed actions to the system. In various examples, the continuous automated loop proceeds while raw events are continuously received from the observed system and monitored. In some examples an application programming interface is described comprising programming statements which allow a user to implement a monitor-mine-manage loop. | 07-10-2014 |
20140330926 | SCALABLE DATA ENRICHMENT FOR CLOUD STREAMING ANALYTICS - A method is described of pre-processing real-time data to be processed by one or more real-time analytics services. The method includes: receiving, at a stateless ingress node, data from one or more client devices; transforming the data in real-time at the stateless ingress node; determining in real-time, at the stateless ingress node, a real-time analytics service for the transformed data; and forwarding in real-time the transformed data to the determined real-time analytics service for stateful processing. | 11-06-2014 |