1. A system, comprising: a memory storing a plurality of instructions; and one or more processors that access the memory, wherein the one or more processors execute the plurality of instructions to at least: identify a continuous query that identifies a data stream; identify a configurable window size; generate a data object to include at least a portion of historical data and that is configured to receive incoming events of the identified data stream that are within a window that corresponds to the configurable window size, the historical data associated with the identified data stream; initialize the continuous query with the data object to process at least the portion of the historical data based at least in part on the window size; and evaluate the data object using the continuous query based at least in part on the data stream and the portion of the historical data.