Managing passthru connections on an operator graph

摘要

Embodiments of the disclosure provide a method, system, and computer program product for processing data such as a stream of tuples. Each tuple can contain one or more attributes. The method can include processing the attributes of the stream of tuples using stream operators operating on one or more computer processors and corresponding to one or more processing elements. The method can also include detecting an indicative element from a plurality of stream operators. The method can also include transmitting, in response to detecting the indicative element, a passthru command to a processing element corresponding to the indicative element. The method can also include altering, in response to receiving the passthru command at the processing element, a portion of attribute processing for the indicative element.

主权项

1. A computer program product for processing a stream of tuples, each tuple containing one or more attributes, the computer program product comprising a computer readable storage medium having program code embodied therewith, the program code comprising computer readable program code configured to:
process the attributes of the stream of tuples using stream operators operating on one or more computer processors and corresponding one or more processing elements; detect an indicative element from a plurality of stream operators; transmit, in response to detecting the indicative element, a passthru command to a processing element corresponding to the indicative element, wherein the transmit the passthru command includes:
determine a performance factor of the passthru command on the processing element,determine a threshold based on resources of a computing system, andselect, in response to the performance factor falling within the threshold, the passthru command; andalter, in response to receiving the passthru command at the processing element, a portion of attribute processing for the indicative element.