Patent Document ID: 8396886
Application ID: 11346119

Base Claim:
1. A computer-implemented method in a continuous processing system, comprising: subscribing to one or more continuous input data streams from one or more publishers of data streams, wherein each of the one or more continuous input data streams is published in a publisher-specific data representation format via a publisher-specific remote communication protocol; executing a query operation directly on the one or more continuous input data streams, including any windows of data within the one or more continuous input data streams, without any pre-processing of the continuous input data streams, including without storing the continuous input data streams in any data structure, prior to said executing, wherein the query operation is executed on a continuous basis; and publishing, in real time and on a continuous basis, a result of the query operation to one or more output data streams in a subscriber-specific data representation format via a subscriber-specific remote communication protocol as subscribed to by one or more subscribers, wherein the publisher-specific remote communication protocol varies from the subscriber-specific remote communication protocol.

---

Claim 2:
2. The computer-implemented method of claim 1 , wherein the executing further comprises: executing a first query operation directly on a first continuous input data stream without any pre-processing of the first continuous input data stream prior to said executing, wherein the first query operation is executed on a continuous basis; subscribing to a second continuous input data stream from the one or more publishers of data streams, wherein the second continuous input data stream is published in a second publisher-specific data representation format via a second publisher-specific remote communication protocol; executing a second query operation directly on the second continuous input data stream without any pre-processing of the second continuous input data stream prior to said executing, wherein the second query operation is executed on a continuous basis; and combining a first result of the first query operation with a second result of the second query operation to produce the result.