FILTER OPTIMIZER FOR DATA STREAMS

摘要

Embodiments of the preset disclosure include a method, a system, and a computer program product for rearranging a set of filters within a data streams environment. The method includes setting a first filter ordering of two or more filter processing elements. The method includes determining a filtering efficiency of the first filter ordering. The determining of the filtering efficiency includes monitoring a runtime, one or more tuples, and an amount of tuples retained after filtering of the first filter ordering. The method includes creating a second filter ordering of the two or more filter processing elements. The method includes comparing the filtering efficiency of the second filter ordering to the first filter ordering. The method includes selecting the second filter ordering in response to comparing the filtering efficiency of the second filter ordering to the filtering efficiency of the first filter ordering.

主权项

1. A method for rearranging a set of filters within a data streams environment comprising:
setting a first filter ordering of two or more filter processing elements; determining a filtering efficiency of the first filter ordering by:
monitoring a runtime of the first filter ordering,monitoring one or more tuples as the one or more tuples pass through the data streams environment, andmonitoring an amount of tuples retained after filtering of the first filter ordering; creating a second filter ordering of the two or more filter processing elements, wherein the second filter ordering of the two or more filter processing elements differ compared to the first filter ordering of the two or more filter processing elements; comparing the filtering efficiency of the second filter ordering to the filtering efficiency of the first filter ordering; selecting the second filter ordering of the two or more filter processing elements, in response to, the comparing of the filtering efficiency second filter ordering to the first filter ordering.