Dynamically changing input data streams processed by data stream language programs

A system for processing data streams, the system comprising:

• at least one memory having instructions stored thereon;
• and
• at least one processor configured to execute the instructions, wherein the at least one processor is configured to:
• receive instructions of a data stream language program, wherein the instructions of the data stream language program are executed periodically at a preset time interval;
• identify a customized block of the data stream language program comprising a first set of the instructions of the data stream language program, the customized block specifying parameter values;
• receive, at the customized block, input data from a plurality of input data streams, each of the plurality of input data streams generated by at least a portion of the data stream language program;
• determine data values for the input data from the plurality of input data streams for each time interval;
• substitute the parameter values in the first set of the instructions of the data stream language program specified by the customized block based on the data values;
• generate a function based on substitute parameter values;
• and
• execute a second set of the instructions of the data stream language program based on the function to generate result data streams.

A non-transitory computer-readable storage medium comprising instructions stored thereon, which when executed by one or more processors, cause the one or more processors to perform operations for processing data streams, comprising:

• receiving instructions of a data stream language program, wherein the instructions are executed periodically at a preset time interval;
• identifying a customized block of the data stream language program comprising a first set of the instructions, the customized block specifying parameter values;
• receiving, at the customized block, input data from a plurality of input data streams, each of the plurality of input data streams generated by at least a portion of the data stream language program;
• determining data values for the input data from the plurality of input data streams for each time interval;
• substituting the parameter values in the first set of the instructions specified by the customized block based on the data values;
• generating a function based on substitute parameter values;
• and
• executing a second set of the instructions based on the function to generate result data streams.