Distributed stream processing

摘要

A regularizer process is started by a first thread executing at a computing device. The regularizer process is a separate process from a process executing on the first thread. The started regularizer process sends a presence announcement to a controller device and receives a presence acknowledgement from the controller device. The started regularizer process sends a notification to the first thread that it is ready to receive streamed data. The started regularizer process receives, from the controller device, an indicator of a data provider system that is to connect to it, receives a connection request from the data provider system, compares the received connection request to the received indicator, sends a connection acknowledgement to the data provider system when the received connection request matches the received indicator, accepts a connection from the data provider system, and receives the streamed data through the connection.

主权项

1. A non-transitory computer-readable medium having stored thereon computer-readable instructions that when executed by a computing device cause the computing device to:
start a regularizer process by a first thread executing at the computing device, wherein the regularizer process is a separate process from a process executing on the first thread; wherein the started regularizer process
sends a presence announcement to a controller device,wherein the presence announcement includes an indicator of the computing device,wherein the controller device controls distribution of analytic results to a data access system,wherein the analytic results are computed from streamed data;receives a presence acknowledgement from the controller device in response to sending the presence announcement;sends a notification to the first thread executing at the computing device that the started regularizer process is ready to receive the streamed data after receiving the presence acknowledgement;receives, from the controller device, an indicator of a data provider system that is to connect to the started regularizer process after sending the notification;receives a connection request from the data provider system;compares the received connection request to the received indicator;sends a connection acknowledgement to the data provider system when the received connection request matches the received indicator;accepts a connection from the data provider system; andreceives the streamed data through the connection.