Patent ID: 9680718
Date: 2017-06-13
CPC Classifications: G06F,H04L

Claim:
1. A method for fusing one or more stream operators into one or more processing elements of a stream computing application, wherein the stream computing application resides on a compute node of a network, comprising: receiving, at a fusion manager, an instruction to concurrently fuse, into a second processing element, a stream operator of interest that is fused into a first processing element, wherein the instruction to concurrently fuse the stream operator of interest into the second processing element is received at run-time via a stream manager and causes the fusion manager to determine how to fuse the stream operator of interest into the second processing element; determining, by the fusion manager, whether the stream operator of interest is stateful; when the stream operator of interest is stateful, the fusion manager sends a clone instruction to a compiler executing on a compiler compute node of the network; compiling, by the compiler, in response to determining the stream operator of interest is stateful, a clone of the stream operator of interest into the second processing element so that the clone is synchronized with the stream operator of interest, by: wherein said receiving the instruction to concurrently fuse the stream operator of interest into the second processing element is based on: wherein the method further comprises: wherein the one or more processing elements includes the one or more stream operators fused together to form an independently running process; wherein the fusion manager and the stream manager are located on a management system and the compiler is located on the compiler compute node of the network separate from the management system.