Adaptive resource allocation for multiple correlated sub-queries in streaming systems

A system for allocating computing resources to process a plurality of data streams, the system comprising:

• a memory device;
• and
• a processor being connected to the memory device,
• wherein the processor is configured to:
• receive at least one query from a user;
• obtain at least one sub-query associated with the at least one query;
• identify at least one data stream associated with the at least one sub-query;
• compute at least one probability that the at least one sub-query is true;
• and
• assign the computing resources to process the data streams according to the computed probability.

A computer program product for allocating computing resources to process a plurality of data streams, the computer program product comprising a storage medium readable by a processing circuit and storing instructions run by the processing circuit for performing a method, the method comprising:

• receiving at least one query from a user;
• obtaining at least one sub-query associated with the at least one query;
• identifying at least one data stream associated with the at least one sub-query;
• computing at least one probability that the at least one sub-query is true;
• and
• assigning the computing resources to process the data streams according to the computed probability.