1. In a continuous computation system, an automated method for processing a set of registered queries over a cluster of servers, wherein each query subscribes to at least one input data stream, the method comprising: creating an execution plan for processing the set of queries over the cluster of servers, where, in creating the execution plan, the system analyzes the semantics and requirements of each of the queries in the set to determine how to distribute processing of the set across the cluster of servers; installing query logic on the cluster of servers in accordance with the execution plan, wherein such logic is installed prior to receiving input messages and wherein logic for an individual query is distributed over a plurality of the servers in the cluster; and continuously running the set of queries over the cluster of servers in accordance with the execution plan; receiving, at the continuous computation system, streaming input messages on one or more input data streams, wherein input messages can arrive continuously; distributing the streaming input messages over the cluster of servers while the set of queries are running; and generating partial outputs for at least one query in the set over two or more servers and using such partial outputs to generate an output data for such query.