Patent ID: 8478743

Claim:
A method, comprising: receiving a first continuous query plan, wherein a continuous query plan is a logical representation of a query, wherein the first continuous query plan comprises a first plurality of operators that continuously perform processing operations on temporal events, at least one temporal event in the temporal events comprising a time window during which the at least one temporal event contributes to an output of the first continuous query plan, the temporal events further comprising at least one revision event, the at least one revision event modifying the time window of the at least one temporal event; receiving a second continuous query plan, wherein the second continuous query plan comprises a second plurality of operators that are configured to continuously perform processing operations on the temporal events, wherein the second continuous query plan is logically equivalent to the first continuous query plan; and using a processor to automatically migrate, in an asynchronous manner, state information of at least one operator in the first plurality of operators to the second continuous query plan.