步骤三:创建实时计算表

本文为实时研发基本流程的创建实时计算表步骤,在准备工作中,订单系统MySQL中的oms_order包含了订单的信息,实时任务就需要从这张表中实时的抽取增量数据来计算GMV。现在我们需要创建一个订单表对应的实时元表,可以从订单表中读取增量数据。

步骤一:创建oms_orders订单来源元表

  1. 在Dataphin首页,单击顶部菜单栏的研发

  2. 按照下图操作指引,进入新建表对话框。

    image.png

  3. 新建表页面,配置相关参数。

    参数

    描述

    表类型

    选择元表。

    元表名称

    填写oms_orders

    数据源

    选择创建的flink_dataphin数据源。

    来源表

    选择oms_orders来源表。

    读取方式

    选择CDC Source表,增量流式读取。

    选择目录

    默认选择表管理

    描述

    填写元表简单的描述。例如,订单来源表

  4. 单击image.png,提交元表。

步骤二:创建ads_gross结果元表

  1. 按照下图操作指引,进入新建表对话框。

    image.png

  2. 新建表页面,配置相关参数。

    参数

    描述

    表类型

    选择元表。

    元表名称

    填写ads_gross

    数据源

    选择创建的flink_dataphin数据源。

    来源表

    选择ads_gross来源表。

    读取方式

    选择JDBC读写表,使用JDBC支持表查询,表写入,用于流写,批读写等。

    选择目录

    默认选择表管理

    描述

    填写元表简单的描述。例如,品类销售总数结果表

  3. 单击image.png,提交元表。