Patent ID: 8560495
Filing Date: 2013-10-15
Classification: G06F

Abstract:
1. A computer-implemented method for synchronizing a processing of messages in a continuous processing system, where the messages are pushed through a directed execution graph that comprises a set of connected primitives, the method comprising: identifying a first primitive of the directed execution graph that causes a delay when executed, wherein a processing of the messages by the first primitive in parallel with a processing of the messages by one or more other primitives of the directed execution graph causes the messages to be processed out of order, the first primitive corresponding to a query statement in a module of the continuous processing system; determining that the first primitive receives a message to be processed by one or more processors in accordance with the query statement, wherein incoming messages to the continuous processing system are assigned a timestamp and divided into time slices, and wherein messages within a time slice have a same timestamp and are processed in parallel; designating one or more second primitives downstream of the identified first primitive in the set of connected primitives as first timezone based on the identified first primitive, the designated first timezone receiving as a first input the processed message from the first primitive, wherein a processing of one or more second primitives in a first timezone prevents the messages from being processed out of order by the one or more other primitives, identifying one or more second inputs to the first timezone that are in addition to the first input from the first primitive, the one or more second inputs including subsequent messages to be processed in the continuous processing system; and synchronizing the first input and the one or more second inputs to the first timezone, wherein the messages in the plurality of messages that need to be processed in parallel enter the first timezone concurrently, and wherein a parallel processing of messages with different internal timestamps does not occur within the first timezone, wherein the identifying of primitives, the designating, the identifying of inputs, and the synchronizing are performed by the one or more processors in the continuous processing system, including providing in an iterative manner at least one second timezone within the first timezone for at least another primitive in the first timezone when the at least one second primitive being executed causes delays.