Altering in-flight streamed data from a relational database

A non-transitory computer-readable media having recorded thereon a computer program having a plurality of computer-executable instructions, wherein the computer program, when executed by at least one computer system, causes the at least one computer system to perform actions comprising:

• receiving in a structured database a modify data command, the modify data command specifying a modify data operation to be applied to each of one or more tuples and logical parameters of tuples to which the modify data command is to be applied;
• responsive to receiving in said structured database the modify data command, forwarding the modify data command from said structured database to a data streaming application, said data streaming application producing output for inclusion in said structured database, wherein said modify data command includes scope data identifying a portion of said data streaming application containing the in-flight data of said data streaming application, said portion being less than all of said data streaming application;
• identifying, in said data streaming application, in-flight data tuples of said data streaming application matching parameters of the forwarded modify data command, wherein said identifying, in said data streaming application, in-flight data of said data streaming application matching parameters of the forwarded modify data command, comprises searching only said portion for the in-flight data matching parameters of the forwarded modify data command;
• and
• applying, in said data streaming application, the modify data operation specified by the modify data command to each tuple identified by said identifying, in said data streaming application, in-flight data tuples of said data streaming application matching parameters of the forwarded modify data command.

A data processing apparatus supporting execution of a data streaming application, comprising:

• at least one physical processor;
• at least one physical memory;
• a data streaming application embodied as instructions executable on the at least one processor and storable in the at least one memory, the data streaming application implementing an operator graph having a plurality of processing elements which operate on data tuples being transferred among processing elements of the plurality of processing elements, the data streaming application receiving input from a source independent of data contained in a structured database and producing output tuples from said input, the output tuples being provided to the structured database for inclusion in the structured database;
• at least one database agent associated with the data streaming application, the at least one database agent embodied as instructions executable on the at least one processor and storable in the at least one memory, wherein the at least one database agent:
• receives a forwarded modify data command from said structured database, the modify data command specifying a modify data operation to be applied to each of one or more tuples and logical parameters of tuples to which the modify data command is to be applied;
• responsive to receiving the forwarded modify data command from said structured database, identifies in-flight data tuples of said data streaming application matching parameters of the forwarded modify data command;
• and
• applies, in said data streaming application, the modify data operation specified by the modify data command to each in-flight data tuple identified by identifying in-flight data tuples of said data streaming application matching parameters of the forwarded modify data command;
• wherein said forwarded modify data command includes scope data identifying a portion of said data streaming application containing the in-flight data of said data streaming application, said portion being less than all of said data streaming application, wherein identifying in-flight data tuples of said data streaming application matching parameters of the forwarded modify data command comprises searching only said portion for the in-flight data tuples of said data streaming application matching parameters of the forwarded modify data command.