CPC G06F 16/285 (2019.01) [G06F 9/542 (2013.01); G06F 11/30 (2013.01); G06F 16/24568 (2019.01); G06F 16/288 (2019.01); G06Q 10/10 (2013.01)] | 20 Claims |
1. A method comprising:
iteratively processing a message through a data stream processing system, wherein the data stream processing system implements at least a first and second stage of processing at least partly in parallel, wherein implementing the first stage of processing includes:
providing a modified message from the data stream processing system to the data stream processing system for continued processing at the second stage of processing, wherein the modified message is generated by modifying content of the message, and
wherein implementing the second stage of processing includes:
providing an output based at least in part on evaluating the modified message according to a set of rules maintained by the data stream processing system.
|