公开(公告)号：US20210406068A1

公开(公告)日：2021-12-30

申请号：US17197804

申请日：2021-03-10

Applicant: Beijing Baidu Netcom Science and Technology Co., Ltd.

Inventor： Weixu CHEN ,  Qing YE

IPC: G06F9/48 ,  G06F16/901

Abstract: A stream computing method and apparatus based on directed acyclic graph (DAG) interaction is provided. A stream computing method based on DAG interaction includes the following steps: generating first DAG job stream description information according to a first DAG node graph composed of DAG nodes belonging to a first type set; converting the first DAG job stream description information into second DAG job stream description information by converting the DAG nodes belonging to the first type set into DAG nodes belonging to a second type set suitable for a FLINK engine; encapsulating the second DAG job stream description information into a DAG execution package, the DAG execution package comprising the second DAG job stream description information and an arithmetic logic of nodes associated with the second DAG job stream description information; and sending the DAG execution package to a job running cluster.