1. An article of manufacture including a non-transitory computer usable medium having computer readable program code embodied therein for continuous querying of a data stream, comprising computer readable program code capable of performing the operations of: initializing a query including query cycles on a query engine to query the data stream for desired information; processing the data stream as segments, wherein a size of the segments is based on a defined parameter; synchronizing the query cycles with the segments of the data stream; analyzing a first segment in a first computer memory by performing the query on the first segment using a processor to obtain a first result; persisting query state of the query and rewinding a query operation to begin a new query cycle; and analyzing a second segment in a second computer memory in the new query cycle by performing the query on the second segment using the processor and based on the first result.
1. An article of manufacture including a non-transitory computer usable medium having computer readable program code embodied therein for continuous querying of a data stream, comprising computer readable program code capable of performing the operations of: initializing a query including query cycles on a query engine to query the data stream for desired information; processing the data stream as segments, wherein a size of the segments is based on a defined parameter; synchronizing the query cycles with the segments of the data stream; analyzing a first segment in a first computer memory by performing the query on the first segment using a processor to obtain a first result; persisting query state of the query and rewinding a query operation to begin a new query cycle; and analyzing a second segment in a second computer memory in the new query cycle by performing the query on the second segment using the processor and based on the first result. 3. An article of manufacture as in claim 1 , wherein the computer readable program code is further capable of receiving a second segment and wherein analyzing the first segment is performed as the second segment is received.