25. In a continuous computation system, a method for distributing processing of a query over a cluster of servers, where the query subscribes to at least one input data stream, the method comprising: determining whether input messages for the query can be processed independent of each other by analyzing the semantics of the query; and in response to determining that input messages for the query can be processed independent of each other: installing identical logic for processing the query on two or more servers in the cluster, wherein such logic is installed prior to receiving input messages; continuously running the query logic on such servers; receiving, at the continuous computation system, streaming input messages on one or more input data streams, wherein input messages can arrive continuously; distributing the input messages among such servers in a round-robin manner; wherein the input messages are distributed while the query is running; generating partial outputs for the query on such servers; and merging the partial outputs to generate output data.
25. In a continuous computation system, a method for distributing processing of a query over a cluster of servers, where the query subscribes to at least one input data stream, the method comprising: determining whether input messages for the query can be processed independent of each other by analyzing the semantics of the query; and in response to determining that input messages for the query can be processed independent of each other: installing identical logic for processing the query on two or more servers in the cluster, wherein such logic is installed prior to receiving input messages; continuously running the query logic on such servers; receiving, at the continuous computation system, streaming input messages on one or more input data streams, wherein input messages can arrive continuously; distributing the input messages among such servers in a round-robin manner; wherein the input messages are distributed while the query is running; generating partial outputs for the query on such servers; and merging the partial outputs to generate output data. 26. The method of claim 25 , where, in generating the partial outputs, the query operates on the input messages in accordance with a time-based window.