Applying advanced energy manager in a distributed environment

A computer program product for processing data in a stream application, the computer program product comprising:

• a non-transitory computer-readable storage medium having computer-readable program code embodied therewith, the computer-readable program code comprising:
• computer-readable program code configured to:
• receive data to be processed by a plurality of processing elements, the processing elements processing at least a portion of the received data;
• establish an operator graph of processing elements, the operator graph defining at least one execution path and wherein each processing element of the operator graph is configured to receive data from at least one upstream processing element and transmit data to at least one downstream processing element;
• identify a downstream processing element that receives data separately from at least two upstream processing elements;
• and
• upon identifying a wait condition where the downstream processing element receives data at different rates from the at least two upstream processing elements, speed up the processing of at least one of the processing elements that precedes the downstream processing element in the at least one execution path.

A system in a data streaming environment, comprising:

• a computer processor;
• and
• a memory containing a program that, when executed on the computer processor, processes data in a stream application, comprising:
• receiving data to be processed by a plurality of processing elements, the processing elements processing at least a portion of the received data;
• establishing an operator graph of processing elements, the operator graph defining at least one execution path and wherein each processing element of the operator graph is configured to receive data from at least one upstream processing element and transmit data to at least one downstream processing element;
• identifying a downstream processing element that receives data separately from at least two upstream processing elements;
• and
• upon identifying a wait condition where the downstream processing element receives data at different rates from the at least two upstream processing elements, speeding up the processing of at least one of the processing elements that precedes the downstream processing element in the at least one execution path.