EXITING WINDOWING EARLY FOR STREAM COMPUTING

摘要

Two or more tuples to be processed by a processing element operating on one or more computer processors may be received by the processing element. The processing element may have a windowing operator performing a windowing operation to determine a first value at the conclusion of a windowing condition. It may be determined from one or more tuples received within the windowing condition whether a condition to end the windowing operation before the windowing condition concludes is met. In addition, the windowing operation may be ended before the windowing condition concludes when the condition to end the windowing operation is met.

主权项

1. A method for processing tuples, comprising:
receiving two or more tuples to be processed by a processing element, the processing element operating on one or more computer processors, the processing element having a windowing operator performing a windowing operation to determine a first value at the conclusion of a windowing condition; determining from one or more tuples received within the windowing condition whether a condition to end the windowing operation is met; and ending the windowing operation before the windowing condition concludes when the condition to end the windowing operation is met.