Streaming Queries
First Claim
Patent Images
1. A system, comprising:
- first and second networked stream operators for operating on a recursive streaming query, wherein the first operator is configured to receive at least two input streams and to generate an output stream based upon a first set of conditions and wherein the second operator is positioned downstream from the first operator and is configured to generate a multicast output, and wherein a portion of the multicast output is recursively directed back as an input to the first operator thereby forming a recursive loop.
2 Assignments
0 Petitions
Accused Products
Abstract
The described implementations relate to recursive streaming queries. One technique processes a recursive streaming query through a query graph. The technique also detects when output produced by executing the query graph advances to a specific point.
-
Citations
20 Claims
-
1. A system, comprising:
first and second networked stream operators for operating on a recursive streaming query, wherein the first operator is configured to receive at least two input streams and to generate an output stream based upon a first set of conditions and wherein the second operator is positioned downstream from the first operator and is configured to generate a multicast output, and wherein a portion of the multicast output is recursively directed back as an input to the first operator thereby forming a recursive loop. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8)
-
9. A method, comprising:
-
processing at least one input stream associated with a recursive streaming query; and
,advancing time for the recursive streaming query to a specific point when the at least one input stream has advanced to the specific point and recursive computations on the input stream are complete to the specific point. - View Dependent Claims (10, 11, 12, 13, 14, 15)
-
-
16. A computer-readable storage media having instructions stored thereon that when executed by a computing device cause the computing device to perform acts, comprising:
-
processing a recursive streaming query through a query graph; and
,detecting when output produced by executing the query graph advances to a specific point. - View Dependent Claims (17, 18, 19, 20)
-
Specification