6. A data processing system for hybrid push/pull of continuous structured query language queries, the data processing system comprising: a bus; a memory connected to the bus, wherein the memory comprises computer executable instructions; a communication unit connected to the bus; a database connected to the bus; a processor unit connected to the bus, wherein the processor unit executes the computer executable instructions to direct the data processing system to: receive stream input, wherein the stream input comprises events of interest; build stream plans based on an original query from the stream input and a state machine, wherein building stream plans comprises splitting the original query into a push sub-query and a pull sub-query, and wherein the pull sub-query represents a portion of the original query from the stream input and the push sub-query represents a remaining portion of the original query from the stream input; replicate the stream input, wherein replicating the stream input comprises copying the stream input to produce a set of input streams, wherein one of the set of input streams is directed to a database and one of the set of input streams is directed to the state machine; responsive to a push sub-query trigger, determine whether a pattern of the push sub-query matches an event in the one of the set of input streams directed to the state machine to form a pattern match and create the push sub-query trigger in response to the pattern match, wherein the pattern match causes submit of the pull sub-query to execute against accumulated data in the database to produce a result; and send the result to a requestor.
9. The data processing system of claim 6 , wherein executing the computer executable instructions to direct the data processing system to build stream plans based on an original query further comprises executing the computer executable instructions to direct the data processing system to: decompose the original query according to selectivities, wherein each of the selectivities represents a percentage of events in the stream input that satisfies a condition; and evaluate costs of stream plans according to the selectivities.