METHOD FOR APPLYING STOCHASTIC CONTROL OPTIMIZATION FOR MESSAGING SYSTEMS
First Claim
1. A computer implemented method for controlling when to send messages in a stream processing system, the computer implemented method comprising:
- determining a policy utilizing probability statistics and a cost function prior to stream processing, wherein the policy specifies under which conditions a message is sent eagerly and under which other conditions the message is delayed;
operating a filter during stream processing that selects which of the messages to send from a sending transform based upon a threshold; and
operating a controller during stream processing that observes a current state of a receiving transform and that applies a policy based on the current state to determine whether to change the threshold.
0 Assignments
0 Petitions
Accused Products
Abstract
A computer implemented method, apparatus, and computer usable program code for controlling when to send messages in a stream processing system. A policy is determined by utilizing probability statistics and a cost function prior to stream processing. The policy specifies under which conditions a message is sent eagerly and under which other conditions the message is delayed. A filter is operated during stream processing that selects which of the messages to send from a sending transform based upon a threshold. A controller is operated during stream processing that observes a current state of a receiving transform and that applies the policy based on the current state to determine whether to change the threshold.
-
Citations
20 Claims
-
1. A computer implemented method for controlling when to send messages in a stream processing system, the computer implemented method comprising:
-
determining a policy utilizing probability statistics and a cost function prior to stream processing, wherein the policy specifies under which conditions a message is sent eagerly and under which other conditions the message is delayed; operating a filter during stream processing that selects which of the messages to send from a sending transform based upon a threshold; and operating a controller during stream processing that observes a current state of a receiving transform and that applies a policy based on the current state to determine whether to change the threshold. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A system comprising:
-
a data processing system for receiving stream data from input streams, wherein the data processing system determines a policy utilizing probability statistics and a cost function, wherein the policy specifies under which conditions messages are sent eagerly and under which other conditions messages are delayed, to minimize an expected cost per time period for sending the messages, and distributes segments onto hosts for correlation processing; and a plurality of hosts operably connected to the data processing system, wherein the messages are sent between each of the plurality of hosts; wherein the data processing system sends the policy to the plurality of hosts for controlling when the messages are sent between the plurality of hosts, wherein a sending host of the plurality of hosts operates a filter that selects which of the messages to send from a sending transform based upon a threshold, and wherein a receiving host of the plurality of hosts includes a controller that senses the threshold and a current state of a receiving transform to implement the policy, and determines whether to change the threshold. - View Dependent Claims (12, 13, 14, 15)
-
-
16. A computer program product comprising a computer usable medium including computer usable program code for controlling messages in a stream processing system, the computer program product comprising:
-
computer usable program code for determining a policy utilizing probability statistics and a cost function prior to stream processing, wherein the policy specifies under which conditions a message is sent eagerly and under which other conditions the message is delayed; computer usable program code for operating a filter during stream processing that selects which of the messages to send from a sending transform based upon a threshold; and computer usable program code for operating a controller during stream processing that observes a current state of a receiving transform, and that applies a policy based on the current state to determine whether to change the threshold. - View Dependent Claims (17, 18, 19, 20)
-
Specification