Suspending and resuming continuous queries over data streams

One or more non-transitory computer-readable media storing one or more sequences of instructions which, when executed by one or more computing devices, cause:

• processing an input data and producing a derived stream therefrom;
• storing the input data stream in an input archive;
• suspending processing of the input data stream;
• and
• subsequent to suspending processing, resuming processing of the input data stream, wherein resuming comprises:
• storing newly received data in the input data stream in a buffer, as the input data stream is streamed;
• determining a first timestamp of a last processed data item;
• determining a second timestamp from the buffered data stream;
• searching the input archive to find a data item that matches the first timestamp of the last processed data item;
• processing particular data in the input archive having timestamps that are greater than the first timestamp until arriving at data with a third timestamp that is greater than the second timestamp;
• processing the input data stream from the buffer;
• and
• continuing processing the input data stream as the input stream is streamed;
• wherein the method is performed by one or more computing devices.