STREAMING DELAY PATTERNS IN A STREAMING ENVIRONMENT

摘要

The method and system receive streaming data to be processed by a plurality of processing elements comprising one or more stream operators. One embodiment is directed to a method and a system for managing processing in a streaming application. A stream operator may select a delay pattern. The stream operator may compare one or more performance factors from the delay pattern to one or more optimal performance factors. The stream operator may delay the stream of tuples using the delay pattern if the performance factors are determined by the optimal performance factors.

主权项

1. A system for managing processing of a stream of tuples, comprising:
a plurality of processing elements to receive a stream of tuples, the processing elements operating on one or more computer processors, each processing element having one or more stream operators, each processing element assigned to one or more compute nodes; an aggregate stream operator, wherein the aggregate stream operator receives the stream of tuples from one or more input stream operators; and a monitor, wherein the monitor measures one or more performance factors, the aggregate stream operator receives the measured performance factors from the monitor, and compares the measured performance factors with an optimal performance factor and selects a delay pattern based on the comparison.