| 摘要 |
Disclosed are a local-based stream computing method and stream computing system. The method comprises: receiving task data through a local upstream computing node; computing the task data by calling a predefined behavior program of the upstream computing node, so as to generate a computing result of the upstream computing node; sending the computing result of the upstream computing node to a downstream computing node to which a data stream of the upstream computing node flows; computing the computing result of the upstream computing node by calling a predefined behavior program of the downstream computing node, so as to generate a computing result of the downstream computing node; and continuing to send the computing result of the downstream computing node to a next downstream computing node to which a data stream of the downstream computing node flows, and computing the computing result of the downstream computing node by calling a predefined behavior program of the next downstream computing node, until a computing node not defining a data stream direction outputs a final computing result of the task data. By implementing the present invention, the computing efficiency can be improved. |
