13-01-2022 дата публикации
Номер: US20220012288A1
Принадлежит:
A stream computing method performed by a manager node includes obtaining input channel description information, a structured query language (SQL) statement, and output channel description information, dynamically generating a data flow diagram according to the input channel description information, the SQL statement, and the output channel description information, and controlling, according to the data flow diagram, a worker node to execute a stream computing task. 1. A stream computing method performed by a manager node of a stream computing system , wherein the stream computing method comprises:generating a first data flow diagram according to input channel description information, a structured query language (SQL) statement, and output channel description information, wherein the first data flow diagram comprises a plurality of logical nodes, wherein the input channel description information defines an input channel, wherein the input channel is a first logical channel for inputting an input data stream from a data production system to the first data flow diagram, wherein the output channel description information defines an output channel, and wherein the output channel is a logical channel for outputting an output data stream of the first data flow diagram to a data consumption system;classifying the logical nodes in the first data flow diagram to obtain a plurality of logical node groups;selecting, from a preset operator library, a common operator corresponding to each logical node group of the logical node groups;generating a second data flow diagram according to the common operator, wherein each operator in the second data flow diagram implements functions of one or more logical nodes in a logical node group corresponding to the operator; andcontrolling, according to the second data flow diagram, a worker node of the stream computing system to execute a stream computing task.2. The stream computing method of claim 1 , wherein the first data flow diagram ...
Подробнее