Patent ID: 8776062

Claim:
A method for processing inquiries over continuous streams of data, the method, including logic when executed by a processor, comprising: identifying a new inquiry to be processed over a continuous dynamic stream of data, the new inquiry newly submitted and not derived from any previous inquiry; identifying a new job plan for execution of the new inquiry, the new job plan comprising an identification of a plurality of best currently available processing elements for processing the continuous dynamic stream of data in accordance with the new inquiry; identifying a previous inquiry determined to be similar to the new inquiry using keyword searches to identify matching keywords in the previous inquiry and the new inquiry according to a predetermined threshold for similarity; and obtaining a previously executed job plan that is associated with the identified previous inquiry, wherein the previously executed job plan includes processing elements that executed the previous inquiry; comparing the previously executed job plan with the new job plan based on pre-defined parameters; wherein the pre-defined parameter comprises determining whether input and output formatting of processing elements in the previously executed job plan and the identified currently available processing elements for the new job plan are the same; and automatically executing, if the input-output formatting is not the same, the previously executed job plan; automatically determining, if the input-output formatting is the same, a number of processing elements that are different between the new and previously executed job plan; and automatically executing, if there is no difference in the number of processing elements between the new and previously executed job plans, the new job plan or the previously executed job plan or both the new job plan and the previously executed job plan.