Patent ID: 9229986
Filing Date: 2016-01-05
CPC Classification: G06F

Claim Text:
1. A method performed by at least one computing device, the method comprising: using multiple operators of an operator graph for processing at least one input stream associated with a recursive streaming query, the at least one input stream comprising events having associated timestamps, the events including first events having first timestamps and second events having second timestamps that are subsequent to the first timestamps; performing recursive computations of the recursive streaming query on the events of the at least one input stream while advancing processing time for the recursive streaming query through multiple time increments based on the timestamps of the events; determining a specific time increment when the recursive computations have been completed for the first events; continuing the recursive computations on the second events while advancing the processing past the specific time increment; and using an individual operator of the operator graph to generate a multicast output from the at least one input stream while the recursive computations are continued on the second events, the multicast output comprising a recursive portion directed to another operator of the operator graph to form a recursive loop and a non-recursive portion comprising a processing output reflecting the processing on at least the first events.