Patent ID: 8380965
Filing Date: 2013-02-19
Classification: G06F,G06Q

Abstract:
1. An apparatus, comprising: a memory device for storing a program; and a processor in communication with the memory device, the processor operative with the program to: facilitate design of a stream processing flow that satisfies an objective, wherein the stream processing flow includes at least three processing groups, wherein a first processing group includes a data source and at least one operator, a second processing group includes a data source and at least one operator and a third processing group includes a join operator at its input and at least one other operator, wherein data inside each group is organized by channels and each channel is a sequence of data, wherein an operator producing a data channel does not generate new data for the channel until old data of the channel is received by all other operators in the same group, and wherein data that flows from the first and second groups to the third group is done asynchronously and is stored in a queue if not ready for processing by an operator of the third group; and deploy the stream processing flow in a concurrent computing system to produce an output.