首页> 外国专利> METHOD AND SYSTEM FOR STREAM COMPUTATION BASED ON DIRECTED ACYCLIC GRAPH (DAG) INTERACTION

METHOD AND SYSTEM FOR STREAM COMPUTATION BASED ON DIRECTED ACYCLIC GRAPH (DAG) INTERACTION

机译:基于定向非循环图(DAG)交互的流计算方法和系统

摘要

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.
机译:提供了一种基于定向非循环图(DAG)交互的流计算方法和装置。 基于DAG交互的流计算方法包括以下步骤:根据属于第一类型集的DAG节点组成的第一DAG节点图生成第一DAG作业流描述信息; 将第一DAG作业流描述信息转换为第二DAG作业流描述信息,通过将属于属于属于用于二芯发动机的第二类型集的DAG节点转换为DAG节点的DAG节点; 将第二DAG作业流描述信息封装到DAG执行包中,该DAG执行包包括第二DAG作业流描述信息和与第二DAG作业流描述信息相关联的节点的算术逻辑; 并将DAG执行包发送到作业运行群集。

著录项

相似文献

  • 专利
  • 外文文献
  • 中文文献
获取专利

客服邮箱:kefu@zhangqiaokeyan.com

京公网安备:11010802029741号 ICP备案号:京ICP备15016152号-6 六维联合信息科技 (北京) 有限公司©版权所有
  • 客服微信

  • 服务号