METHOD AND APPARATUS FOR PROVIDING A FILTER JOIN ON DATA STREAMS
First Claim
1. A method for processing at least one data stream, comprising:
- receiving at least a join query for the at least one data stream, wherein said join query specifies a lifetime for keeping a tuple as a marker for a beginning of a sequence of interest;
receiving a tuple from the at least one data stream;
marking said tuple as a beginning of a sequence of interest and storing said tuple in accordance with the lifetime specified in said join query, if said tuple is said beginning of said sequence of interest;
applying one or more initial predicates to said tuple;
determining if said tuple matched a marked tuple, if said tuple meets the one or more initial predicates.determining if said tuple meets one or more conditions to be outputted, if said tuple meets said one or more initial predicates conditions; and
outputting said tuple as a result to said join query if said tuple meets said one or more conditions to be outputted.
1 Assignment
0 Petitions
Accused Products
Abstract
A method and apparatus for processing at least one data stream are disclosed. For example, the method receives at least a join query for the at least one data stream, wherein the join query specifies a lifetime for keeping a tuple as a marker for a beginning of a sequence of interest, and receives a tuple from the at least one data stream. The method marks the tuple as a beginning of a sequence of interest and stores the tuple, if the tuple is the beginning of the sequence of interest. The method applies one or more initial predicates to the tuple, and determines if the tuple matched a marked tuple, if the tuple meets the one or more initial predicates. The method determines if the tuple meets one or more conditions to be outputted, if the tuple meets the one or more initial predicates conditions.
53 Citations
20 Claims
-
1. A method for processing at least one data stream, comprising:
-
receiving at least a join query for the at least one data stream, wherein said join query specifies a lifetime for keeping a tuple as a marker for a beginning of a sequence of interest; receiving a tuple from the at least one data stream; marking said tuple as a beginning of a sequence of interest and storing said tuple in accordance with the lifetime specified in said join query, if said tuple is said beginning of said sequence of interest; applying one or more initial predicates to said tuple; determining if said tuple matched a marked tuple, if said tuple meets the one or more initial predicates. determining if said tuple meets one or more conditions to be outputted, if said tuple meets said one or more initial predicates conditions; and outputting said tuple as a result to said join query if said tuple meets said one or more conditions to be outputted. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9)
-
-
10. A computer-readable storage medium having stored thereon a plurality of instructions, the plurality of instructions including instructions which, when executed by a processor, cause the processor to perform steps of a method for processing at least one data stream, comprising:
-
receiving at least a join query for the at least one data stream, wherein said join query specifies a lifetime for keeping a tuple as a marker for a beginning of a sequence of interest; receiving a tuple from the at least one data stream; marking said tuple as a beginning of a sequence of interest and storing said tuple in accordance with the lifetime specified in said join query, if said tuple is said beginning of said sequence of interest; applying one or more initial predicates to said tuple; determining if said tuple matched a marked tuple, if said tuple meets the one or more initial predicates. determining if said tuple meets one or more conditions to be outputted, if said tuple meets said one or more initial predicates conditions; and outputting said tuple as a result to said join query if said tuple meets said one or more conditions to be outputted. - View Dependent Claims (11, 12, 13, 14, 15, 16, 17, 18)
-
-
19. An apparatus for processing at least one data stream, comprising:
-
means for receiving at least a join query for the at least one data stream, wherein said join query specifies a lifetime for keeping a tuple as a marker for a beginning of a sequence of interest; means for receiving a tuple from the at least one data stream; means for marking said tuple as a beginning of a sequence of interest and storing said tuple in accordance with the lifetime specified in said join query, if said tuple is said beginning of said sequence of interest; means for applying one or more initial predicates to said tuple; means for determining if said tuple matched a marked tuple, if said tuple meets the one or more initial predicates. means for determining if said tuple meets one or more conditions to be outputted, if said tuple meets said one or more initial predicates conditions; and means for outputting said tuple as a result to said join query if said tuple meets said one or more conditions to be outputted. - View Dependent Claims (20)
-
Specification