Business processing method, device and system

Abstract

The invention discloses a business processing method. A working node acquires operators in a stream-oriented computation application model dispatched by a master node, the operators in the stream-oriented computation application model and data stream directions among the operators form at least one iteration loop, iteration times corresponding to each iteration loop is configured on an outlet operator of each iteration loop, the outlet operator is the last operator in the data stream direction of each iteration loop and receives business data, and the business data are processed according to a partial processing logic carried by each operator and are outputted from the outlet operator when the fact that the iteration times of the business data reaches that of the iteration loop with each outlet operator is determined according to the partial processing logic carried of each outlet operator. By the business processing method, data processing delay can be reduced, and data processing instantaneity is improved.

Description

technical field [0001] The present invention relates to the field of computer technology, in particular to a business processing method, device and system. Background technique [0002] Real-time stream computing means that data is processed immediately when it appears, and an event is processed once, instead of being cached and processed in batches. Computing systems that support real-time stream computing are called stream computing systems or stream computing platforms. [0003] In a stream computing system, business processing logic usually needs to be transformed into a stream computing application model. The stream computing application model is usually a Directed Acyclic Graph (DAG), also known as an application flow graph, such as figure 1 As shown, the stream computing application model is mainly composed of operators and streams, where an operator is a data processing unit that carries business logic and is the smallest unit that can be distributed and scheduled by...

AI Technical Summary

Problems solved by technology

[0006] In order to solve the problems of high time delay and poor real-time performance of iterative processing in the prior art, a business processing method provided by the embodiment of the present invention directly performs iterative processing on the received business data without first storing it, which can reduce the The processing delay of business data improves real-time performance

Images