Managing a grouping window on an operator graph

摘要

Embodiments of the disclosure provide a method, system, and computer program product for managing a windowing operation. The method can include determining a sentinel value that defines a start of a grouping window for a stream of tuples and a terminating sentinel value that defines the end of the grouping window based upon an attribute contained in the stream of tuples. The stream of tuples can be monitored for the sentinel value and the terminating sentinel value by a stream operator. The stream operator can initiate a windowing operation that defines the start of the grouping window in response to a presence of the sentinel value and terminate the windowing operation in response to a presence of the terminating sentinel value.

主权项

1. A system for processing a stream of tuples, each tuple having one or more attributes, comprising:
one or more processing elements operating on one or more computer processors configured to processes the attributes from the stream of tuples, each processing element configured to:
determine a sentinel value that defines a start of a grouping window for the stream of tuples and a terminating sentinel value that defines an end of the grouping window, wherein both the sentinel value and the terminating sentinel value are based upon attributes contained in the stream of tuples;monitor tuples within the stream of tuples for a tuple with the sentinel value;detect the tuple with the sentinel value by monitoring tuples for the tuple with the sentinel value;initiate the grouping window in response to detecting the tuple with the sentinel value, wherein tuples that are subsequent to the tuple with the sentinel value within the grouping window undergo a windowing operation;monitor tuples within the stream of tuples that are subsequent to the tuple with the sentinel value for a tuple with the terminating sentinel value;detect the tuple with the terminating sentinel value by monitoring tuples for the tuple with the terminating sentinel value; andterminate the grouping window in response to detecting the tuple with the terminating sentinel value, wherein tuples of the stream of tuples that are subsequent to the tuple with the terminating sentinel value do not undergo the windowing operation.