Patent ID: 11921724
Assignee: INTERNATIONAL BUSINESS MACHINES CORPORATION
Field: Computer technology (Electrical engineering)
Classification: CPC G | IPC G

Claim 13:
14. A computer program product for processing a stream of tuples in a stream computing application, the computer program product comprising a computer readable storage medium having program code embodied therein, the program code comprising computer readable program code configured to cause one or more computer processors to perform a method comprising:
receiving a stream of tuples to be processed by the stream computing application deployed on a network, the stream computing application including a plurality of stream operators executing on the one or more computer processors, the plurality of stream operators being arranged according to an operator graph for the stream computing application;
generating a window over two or more stream operators of the plurality of stream operators, the window including a breakpoint threshold;
determining a tuple flow count for the window, the tuple flow count corresponding to the breakpoint threshold;
determining that a breakpoint condition has occurred by comparing the tuple flow count to the breakpoint threshold;
modifying, during runtime, in response to determining that the breakpoint condition has occurred, the stream computing application by dynamically editing processing elements and the stream operators of the stream computing application; and
implementing, on the network in response to modifying, the processing elements and stream operators to actuate a tuple flow change to the stream computing application; and
modifying a first stream operator to process a first portion of tuples received by the first stream operator and not process a second portion of tuples received by the first stream operator, wherein the first portion of tuples includes tuples of a first type and the second portion of tuples includes tuples of a second type,
wherein implementing the tuple flow change comprises severing an execution path between two stream operators, and, wherein stream operators that are configured to transmit tuples along the severed execution path no longer transmit tuples along the severed execution path.