Oracle International Corporation

International Business Machines Corporation

Pavan L Advani

Hoyong Park

Prabhu Thukkaram

Sandeep Bishnoi

Santosh Kumar

Jeffrey Toillion

Kunal Mulay

An event processing system for processing events in an event stream is disclosed. The system can execute instructions to receive a continuous query, apply a transformation to the continuous query to generate a query plan for the continuous query, transform the query plan using a transformation algorithm to generate a transformed query plan, receive a micro-batch stream of input events related to an application, process the input events of the micro-batch stream based at least in part on the transformed query plan to generate a set of output events related to the application, and store the set of output events related to the application in an output queue.

Complex event processing for micro-batch streaming

An event processing system for processing events in an event stream is disclosed. The system can execute instructions to receive a continuous query, apply a transformation to the continuous query to generate a query plan for the continuous query, monitor the continuous query using a monitoring transformation process, receive a micro-batch stream of input events related to an application, and process the input events of the micro-batch stream based at least in part on the monitoring transformation process to generate a set of output events related to the application.

Non-intrusive monitoring output of stages in micro-batch streaming

An event processing system for processing events in an event stream is disclosed. The system can execute instructions to receive a micro-batch stream of input events, process the input events using the CQL engine to generate a set of output events, generate, using a snapshot management algorithm implemented by the CQL engine, a snapshot of a current state of a system based at least in part on the set of output events related to the application, generate a first directory structure to access snapshot information associated with the snapshot of the current state of the system, generate a second directory structure to generate a list of snapshots associated with the current state of the system, and determine based at least in part on the snapshot management algorithm, a process to get, add, or clean the list of snapshots associated with the current state of the system.

Managing snapshots and application state in micro-batch based event processing systems

An aspect of the present disclosure facilitates reporting results of processing of continuous event streams. In one embodiment, a matching condition indicating a pattern of interest as a part of an alert definition in relation to a set of continuous event streams is received, with the occurrences of said pattern of interest being desirable to be reported as corresponding alert instances. Also, a suppression condition associated with the pattern of interest is received, with the suppression condition indicating the specific occurrences of the pattern of interest that are not to be reported as corresponding alert instances. Accordingly, a sequence of occurrences of the pattern of interest is determined in the set of continuous event streams. For each occurrence in the sequence of occurrences, an alert instance corresponding to the occurrence is generated only if the suppression condition is not satisfied for the occurrence.

Reporting results of processing of continuous event streams

An aspect of the present invention facilitates users to view temporal values for multiple fields. In one embodiment, a first value and a second value are displayed respectively for a first field and a second field, with the first value and second value representing temporal values at a first time instance for the two fields respectively. Upon receiving data representing a second time instance, the display is updated by displaying a third value and a fourth value for the first field and the second field respectively, with the third value and the fourth value representing corresponding temporal values at the second time instance for the two fields.

Facilitating viewing of temporal values for multiple fields

Navigation to a data definition in a diff context. A diff comparison can be generated between at least two versions of a first file. The diff comparison can identify syntax of at least a first method identified in a portion of syntax that is different between the at least two versions of the first file, the first method defined by a data definition in a second file. The diff comparison can configure syntax of the first method to be a first navigable block of data in at least one of the versions of the first file. At least two versions of the first file can be presented to a user in a file difference window, and a user input can be received selecting the first navigable block of data. Responsive to the user input, the second file can be presented to the user in the file difference window.

Navigation to a data definition in a diff context

In and for software projects, arrangements for permitting a user to understand how the spatial locality of a function call may have changed with respect to any changes in a function definition. This permits an analysis of different workflows which use the same function, wherein the definition of the function may have changed. To the extent that there might be corresponding changes in the workflows which use such a function, the user will readily develop an idea of why some workflows changed and some did not. The invention method and apparatus determine and display deltas (changes) between different versions of a file where the function call occurs.

Growing community of inventors

Karnataka, India

Pavan L Advani