1. A method for performing event stream processing comprising: receiving an input query; parsing the input query into a directed acyclic graph (DAG) including a plurality of operator nodes; creating a grouping of one or more of the operator nodes; creating one or more partitions in the DAG by forming one or more duplicates of the grouping; creating a splitter node in the DAG, the splitter node splitting data from one or more event streams among the grouping and the one or more duplicates of the grouping; and resolving the input query by processing data from one or more event streams using the DAG.