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 comprising at least a first distributed data processing node in a first data center and a second distributed data processing node in a second data center, wherein the first data center and the second data center are separate; the first distributed data processing node locally processing the parallel portion against a first independent data stream to produce a first partial summary data, and sending the first partial summary data to the unified data processing node, wherein the first independent data stream is not duplicated or processed by the unified data processing node or the second distributed data processing node; the second distributed data processing node locally processing the parallel portion against a second independent data stream to produce a second partial summary data, and sending the second partial summary data to the unified data processing node, wherein the second independent data stream is not duplicated or processed by the unified data processing node or the first distributed data processing node; continuously receiving, at the unified data processing node, in real-time, streaming data results comprising the first partial summary data and the second partial summary data and combining the first partial summary data and the second partial summary data in preparation for returning combined streaming query results to an application; and wherein the method is performed by one or more computing devices.