Patent ID: 7467066

Claim:
A method on an information processing system for benchmarking a stream processing system, the method comprising: generating a plurality of correlated test streams; embedding a semantically related data set within each of the test streams in the plurality of correlated test streams; providing the plurality of correlated test streams to at least one stream processing system, whereby the stream processing system produces an output data set including a set of zero or more correlation results; generating a summary for each of the semantically related embedded data sets; storing a copy of each summary in memory; embedding a common identifier within each stream in the plurality of correlated test streams, wherein the common identifier is transparent to the at least one stream processing system so as not to affect the set of the correlation results, and wherein the common identifier uniquely identifies the plurality of correlated test streams; extracting the common identifier from the output data set generated by the stream processing system; and comparing at least one of the common identifier and the stored copies of the summaries to the output data set generated by the stream processing system.