Dynamic execution of parameterized applications for the processing of keyed network data streams

A method performed by a data processing system for segmenting one or more data items associated with one or more respective key values and one or more respective attributes by executing a computer program for processing the one or more data items associated with the one or more respective key values and the one or more respective attributes, and, for a particular key value, selecting, from among one or more rules, a particular rule to be applied, if the computer program is in a particular state with respect to the particular key value and the one or more data items are associated with one or more attributes of the particular rule, the method including:

• identifying a computer program that processes one or more data items, with the one or more data items being associated with one or more key values and one or more attributes;
• executing the computer program to process the one or more data items, wherein one or more states of the computer program are maintained for the one or more key values, the executing including:
• for one or more data items associated with a particular key value, identifying first and second states of the computer program, with each of the first and second states being associated with the particular key value;
• based on determining that the computer program is in the first state, with respect to the particular key value, identifying one or more rules;
• wherein a rule specifies one or more attributes and further specifies one or more actions to be performed upon selection of the rule, with the rule being selected if the computer program is in the first state, with respect to the particular key value, and the one or more data items are associated with the one or more attributes of the rule;
• comparing one or more attributes of the one or more rules in accordance with the computer program being in the first state with respect to the key value, to one or more attributes of the one or more data items associated with the particular key value;
• based on the comparing, selecting, from among the one or more rules in accordance with the computer program being in the first state with respect to the key value, a rule specifying the one or more attributes of the one or more data items associated with the particular key value;
• causing the one or more actions specified by the selected rule to be performed;
• and
• causing the computer program, with respect to the particular key value, to transition from the first state to the second state.

A method performed by a data processing system for adjusting one or more actions to be performed in response to processing, by a computer program, one or more data items associated with a key value by identifying one or more rules for adjusting the one or more actions, if the computer program is in a particular state with respect to the key value, the method including:

• identifying a computer program that processes one or more data items and identifies one or more actions to perform based on processing the one or more data items, the one or more data items being associated with one or more key values;
• and
• executing the computer program to process the one or more data items, wherein one or more states of the computer program are maintained for the one or more key values, the executing including:
• for one or more data items associated with a particular key value, identifying first and second states of the computer program, with at least the first state of the computer program, with regard to the particular key value, being associated with:
• one or more actions to be performed in that first state of the computer program with regard to the particular key value and one or more rules for adjusting the one or more actions to be performed in the first state of the computer program with regard to the particular key value;
• identifying the one or more actions to be performed in accordance with the computer program being in the first state with respect to the particular key value;
• identifying the one or more rules to adjust the one or more actions to be performed in accordance with the computer program being in the first state with respect to the particular key value;
• comparing the one or more rules to the one or more data items associated with the particular key value;
• based on the comparing, adjusting the at least one of the one or more actions in accordance with the computer program being in the first state with respect to the particular key value associated with the one or more data items;
• and
• causing the computer program, with respect to the particular key value, to transition from the first state to the second state.

A data processing system for segmenting one or more data items associated with one or more respective key values and one or more respective attributes by executing a computer program for processing the one or more data items associated with the one or more respective key values and the one or more respective attributes, and, for a particular key value, selecting, from among one or more rules, a particular rule to be applied, if the computer program is in a particular state with respect to the particular key value and the one or more data items are associated with one or more attributes of the particular rule, the data processing system including:

• a detection sub-system configured to identify a computer program that processes one or more data items, with the one or more data items being associated with one or more key values and one or more attributes;
• wherein the detection sub-system configured to execute the computer program to process the one or more data items, wherein one or more states of the computer program are maintained for the one or more key values, the executing including:
• for one or more data items associated with a particular key value, identifying first and second states of the computer program, with each of the first and second states being associated with the particular key value;
• based on determining that the computer program is in the first state, with respect to the particular key value, identifying one or more rules;
• wherein a rule specifies one or more attributes and further specifies one or more actions to be performed upon selection of the rule, with the rule being selected if the computer program is in the first state, with respect to the particular key value, and the one or more data items are associated with the one or more attributes of the rule;
• comparing one or more attributes of the one or more rules in accordance with the computer program being in the first state with respect to the key value, to one or more attributes of the one or more data items associated with the particular key value;
• based on the comparing, selecting, from among the one or more rules in accordance with the computer program being in the first state with respect to the key value, a rule specifying the one or more attributes of the one or more data items associated with the particular key value;
• an instruction sub-system configured to cause, for the one or more data items associated with the particular key value, the one or more actions specified by the selected rule to be performed;
• and
• wherein the instruction sub-system configured to cause the computer program, with respect to the particular key value, to transition from the first state to the second state.