| 主权项 |
1. A method, comprising:
receiving, by one or more processors, a plurality of string matching requests with respect to a plurality of data streams; determining, by the one or more processors, one or more opportunities for aggregation of string matching in the form of one or more subsets of requests of the plurality of string matching requests, the determining comprising:
registering an identity of a first data stream of the plurality of data streams,extracting information from the first data stream,receiving indication from one or more data providers that duplicate streams of data are being requested from the one or more data providers, andidentifying the one or more subsets of requests of the plurality of string matching requests for processing of the first data stream based on the registered identity, the extracted information, and the received indication; and aggregating string matching for the identified one or more subsets of requests, wherein the aggregating comprises:
detecting a difference in time between at least two streams of the plurality of data streams,composing a combined dictionary from a plurality of dictionaries each of which including a respective plurality of strings,redirecting a leading stream of the plurality of data streams and activating output routing for a first request of the one or more subsets of requests, anddelaying redirection of the one or more next leading streams in an order from leading to lagging in time with activation of output routing for the associated one or more requests until all the one or more subsets of requests are provided with results of string matching from the first data stream. |
