1. A method comprising: receiving, at a unified data processing node, a continuous query; determining a parallel portion of the continuous query; sending the parallel portion to a plurality of distributed data processing nodes located in a plurality of data centers, each distributed node in the plurality of distributed data processing nodes, locally executing the parallel portion against independent data partitions, producing a partial summary data, and sending the partial summary data to the unified node; continuously receiving, at the unified node, in real-time, the partial summary data; and wherein the method is performed by one or more computing devices.