A non-transitory computer-readable medium having stored thereon computer-readable instructions that when executed by a first computing device cause the first computing device to: create a local event stream processing (ESP) model based on information read from a manager configuration file , wherein the local ESP model describes first computational processes to be performed on one or more first fields of an event block object when the event block object is received by the first computing device from a second computing device remote from the first computing device , wherein the manager configuration file includes first connection information to connect the second computing device and the first computing device ; instantiate an ESP engine (ESPE) on the first computing device based on the created local ESP model ; receive the event block object from the second computing device in a first source window of the instantiated ESPE , wherein the first source window is defined by the created local ESP model as a processing node of a directed graph that defines a continuous query and into which the event block object is published by the second computing device ; process the received event block object based on the created local ESP model ; deploy a remote ESP model to a third computing device remote from the first computing device and from the second computing device , wherein the remote ESP model describes second computational processes to be performed on one or more second fields of the processed event block object when the processed event block object is received by the third computing device from the first computing device , wherein the manager configuration file further includes an indicator of the remote ESP model and second connection information to connect the third computing device and the first computing device ; select the third computing device to receive the processed event block object ; and publish the processed event block object to a second source window defined by the remote ESP model deployed to the third computing device . create a local event stream processing (ESP) model based on information read from a manager configuration file , wherein the local ESP model describes first computational processes to be performed on one or more first fields of an event block object when the event block object is received by the first computing device from a second computing device remote from the first computing device , wherein the manager configuration file includes first connection information to connect the second computing device and the first computing device ; instantiate an ESP engine (ESPE) on the first computing device based on the created local ESP model ; receive the event block object from the second computing device in a first source window of the instantiated ESPE , wherein the first source window is defined by the created local ESP model as a processing node of a directed graph that defines a continuous query and into which the event block object is published by the second computing device ; process the received event block object based on the created local ESP model ; deploy a remote ESP model to a third computing device remote from the first computing device and from the second computing device , wherein the remote ESP model describes second computational processes to be performed on one or more second fields of the processed event block object when the processed event block object is received by the third computing device from the first computing device , wherein the manager configuration file further includes an indicator of the remote ESP model and second connection information to connect the third computing device and the first computing device ; select the third computing device to receive the processed event block object ; and publish the processed event block object to a second source window defined by the remote ESP model deployed to the third computing device . <EOS>