Patent ID: 9514159
Filing Date: 2016-12-06
CPC Classification: G06F

Claim Text:
1. A method, comprising: receiving a data stream to be processed in a data streaming environment comprising a plurality of processing elements interconnected by an operator graph, and wherein each of the processing elements is configured to receive an incoming tuple and perform a respective one or more processing operations on the incoming tuple, and wherein at least one of the plurality of processing elements is configured to generate, as a result of the respective one or more processing operations, an output tuple and to transmit the output tuple, based on the operator graph, to at least one downstream processing element in the plurality of processing elements; loading a trigger rule on both a first processing element and a second processing element in the plurality of processing elements, wherein the trigger rule includes a trigger condition and defines a processing action to be performed upon satisfaction of the trigger condition on both the first processing element and the second processing element; upon determining that a first tuple received at the first processing element satisfies the trigger condition and that a second tuple received at the second processing element satisfies the trigger condition, performing the processing action defined by the trigger rule on at least one of the first tuple, the second tuple and information related to the data stream; storing at least one of information related to the data stream at the time the trigger condition was satisfied and the first tuple in a database, wherein the storing includes formatting the at least one of the information related to the data stream and the first tuple according to a predefined format in the trigger rule; wherein the plurality of processing elements are communicatively coupled to a management system configured to monitor and control operations of the plurality of processing elements, wherein the management system is further configured to monitor a database to detect occurrences of a pre-defined event defined by a second trigger rule, and to perform a second processing action defined by the second trigger rule upon detecting an occurrence of the pre-defined event.