11. A method, comprising: receiving a plurality of events via an input stream, wherein a query application plan is compiled prior to receiving the plurality of events and wherein the query application plan determines partitioning logic that partitions the plurality of events; partitioning the plurality of events into one or more groups; instantiating a query application module for each of the one or more groups, wherein each particular query application module for a particular group is configured to apply a query to events of the particular group to generate partial results; merging the partial results of each of the query application modules to generate merged output results; and providing the merged output results to an output stream.
11. A method, comprising: receiving a plurality of events via an input stream, wherein a query application plan is compiled prior to receiving the plurality of events and wherein the query application plan determines partitioning logic that partitions the plurality of events; partitioning the plurality of events into one or more groups; instantiating a query application module for each of the one or more groups, wherein each particular query application module for a particular group is configured to apply a query to events of the particular group to generate partial results; merging the partial results of each of the query application modules to generate merged output results; and providing the merged output results to an output stream. 15. The method of claim 11 , further comprising deleting an existing query application module for a group in response to determining that the group does not include any events.