| 摘要 |
A streaming graph optimization method and apparatus, which relate to the field of stream processing. The method comprises: receiving a stream application streaming graph provided by a user (S601); parsing the streaming graph, and constructing a streaming graph described by an operator node and a data stream edge (602); disassembling the streaming graph according to a maximum atom division rule, so as to obtain at least one sub-streaming graph (S603); and performing adjacent operator combination on the at least one sub-streaming graph according to a combination algorithm, so as to obtain an optimized streaming graph (S604). By means of disassembling and combining a streaming graph provided by a user, the balance of streaming graph computation logic and the reduction of redundant traffic transmission are realized, thereby improving the utilization rate of a stream system resource and the execution performance of a stream application. |
