Patent ID: 9575872
Date: 2017-02-21
CPC Classifications: G06F

Claim:
1. An apparatus comprising: at least one processor; a memory coupled to the at least one processor; a streaming application residing in the memory and executed by the at least one processor, the streaming application comprising an operator graph that includes a plurality of operators that process a plurality of data tuples; a performance monitor residing in the memory and executed by the at least one processor, the performance monitor monitoring each of the plurality of data tuples processed by the plurality of operators in the operator graph to determine time for the plurality of operators to process each of the plurality of data tuples and a number of times each of the plurality of operators process each of the plurality of data tuples; and a tuple breakpoint mechanism residing in the memory and executed by the at least one processor, the tuple breakpoint mechanism including at least one tuple breakpoint that fires when at least one of the plurality of data tuples has been processed more than a specified limit for processing the at least one data tuple by all of the plurality of operators that process the at least one data tuple, and when the tuple breakpoint mechanism determines the tuple breakpoint fires based on information from the performance monitor, the tuple breakpoint mechanism halts at least one operator in the operator graph and displays information regarding a data tuple that caused the tuple breakpoint to fire.