实时计算元表帮助您统一配置与管理实时计算任务开发过程中用到的输入表、输出表、维表。本文为您介绍如何新建实时计算元表。

背景信息

  • 实时计算元表只有在解锁的状态下,才支持编辑、移动、克隆和删除等操作。
    • 如果实时计算元表已被您自己锁定,则无需解锁实时计算元表。
    • 如果实时计算元表已被他人锁定,则执行以下操作,解锁实时计算元表:
      1. 在实时计算元表页面,单击需要编辑、移动、克隆或删除等操作的实时计算元表。
      2. 在实时计算元表的详情页面,单击右上方的ysga图标。

        ysga图标变更为tagag图标时,该实时元表解锁成功。

  • 管理实时计算元表的权限限制,详情参见数据开发权限列表

操作步骤

  1. 登录Dataphin控制台
  2. 在Dataphin控制台页面,选择工作区地域后,单击进入Dataphin>>
    您可以通过以下方式,快速进入工作区:
    • 选择工作区地域后,单击快速开始相关工作区域中的数据研发
    • 选择工作区地域后,单击快速进入研发项目后的DevBasic页签,选择相应的项目。
    说明
    • 如果您通过快速开始相关工作进入数据开发模块,则跳过步骤3.i。
    • 如果您通过快速进入研发项目进入数据开发模块,则跳过步骤3.ii。
  3. 进入实时计算元表页面。
    1. 在Dataphin首页,单击顶部菜单栏的研发
    2. 在数据开发页面,单击项目名称后的test图标,选择数据开发的项目空间(DevBasic项目)。
      如果您当前访问的是DevBasic项目,且项目空间为您的数据开发空间,则不需要选择项目空间。
    3. 在数据开发页面,单击数据处理
    4. 数据处理页签,单击左侧导航栏vrdho实时计算元表图标。
  4. 实时计算元表页面,您可以通过以下方式,进入新建实时计算元表
    • 单击实时计算元表后的图标。
    • 单击项目名称后的图标,选择数据处理 > 实时计算元表
    • 开发首页,单击实时计算元表后的图标。
  5. 新建实时计算元表对话框,配置参数。
    不同数据源的配置参数不同,请根据页面提示完成参数的配置。
  6. 单击确定
  7. 可选:添加字段。
    gaga
    • 通过SQL导入的方式添加字段:
      1. 在实时元表页面,鼠标悬停至添加字段上,选择SQL导入
      2. SQL导入对话框中,编写SQL代码,代码示例如下。
        create table dwi_pub_hbd_cate_mtr ( 
            rowkey  VARCHAR  comment 'rowkey',
            stat_date  VARCHAR  comment 'stat_date',
            keymin  VARCHAR  comment 'keymin',
            PRIMARY KEY(rowkey)
          )
           with ( 
              type='alihbase',
              diamondGroup='null',
              zkQuorum='hbasemaster74000.sg94.tbsite.net,hbasemaster74001.sg94.tbsite.net,hbasemaster74002.sg94.tbsite.net,hbase74000.sg94.tbsite.net,hbase74001.sg94.tbsite.net',
              diamondKey='null',
              zkNodeParent='/group-sg94-lzd-mix',
              columnFamily='info',
              tableName='dwi_pub_hbd_cate_mtr_001',
              stringWriteMod='true'
          );
      3. 单击确定,完成字段的添加。
    • 通过批量导入的方式添加字段:
      1. 在实时元表页面,鼠标悬停至添加字段上,选择批量导入
      2. 批量导入对话框中,编写代码,代码示例如下。
        ID,INT,描述,false,true,
        name,INT,描述,false,true
    • 通过单行添加的方式添加字段:
      1. 在实时元表页面,鼠标悬停至添加字段上,选择单行添加
      2. 单行添加对话框,配置参数。
      3. 单击确定,完成字段的添加。
    同时,您可以对已添加的字段,执行如下操作。
    操作 描述
    编辑 执行如下操作,编辑字段:
    1. 在实时计算元表页面,单击操作列下的图标。
    2. 根据编辑页面的提示,修改参数。
    3. 完成参数修改后,单击完成
    删除 执行如下操作,删除字段:
    1. 在实时计算元表页面,单击操作列下的图标。
    2. 提示对话框中,单击确定并提交,完成字段的删除。
    排序 执行如下操作,重新排序字段:
    1. 在实时计算元表页面,单击排序
    2. 根据页面提示,单击完成,完成字段的排序。
    搜索 在搜索框中输入字段的名称或字段名称关键字进行搜索字段。
    刷新 单击图标,重新解析元表中的字段。
  8. 保存并提交实时计算元表。
    1. 在实时计算元表的开发页面,单击右上角的图标,保存实时计算元表。
    2. 在实时计算元表的开发页面,单击右上角的图标,提交实时计算元表。
    3. 提交备注对话框,填写备注信息。
    4. 单击确定并提交
  9. 可选:发布实时计算元表至生产环境。
    • 如果您的开发模式是Dev-Prod模式,则需要发布实时计算元表,详情请参见管理发布任务
    • 如果您的开发模式是Basic模式,则提交成功的实时计算,即可进入生产环境。
    对已添加的实时计算元表,您可以执行如下操作。
    操作 描述
    查看实时计算元表版本信息
    1. 实时计算元表页面,单击需要查看的实时计算元表。
    2. 在实时计算元表详情页面,单击版本信息,可以查看历史版本提交情况:
      • 单击操作列下的图标,查看版本对比。

        同时,单击回滚到对比版本,回滚到历史版本。

      • 单击操作列下的图标,查看代码。
    修改实时计算元表 您可以通过修改实时计算元表的方式,修改实时计算元表的基本信息和字段:
    1. 实时计算元表页面,将鼠标悬停在需要修改的实时计算元表后的图标,单击编辑
    2. 修改实时计算元表的基本信息:
      1. 在实时元表详情页面,单击页面上方的元表信息
      2. 元表信息对话框,修改参数。
        • 如果实时计算元表是基于系统提供的实时数据源类型构建的,则您可以修改数据源来源topic描述参数KV配置
        • 如果实时计算元表是基于自定义实时数据源构建的,则您可以修改数据源描述参数KV配置
      3. 单击确定
    3. 在实时元表详情页面,您可以添加、修改或删除实时计算元表的字段。
    4. 提交或发布实时计算元表。
    移动实时计算元表
    1. 实时计算元表页面,将鼠标悬停在需要移动的实时计算元表后的图标,单击移动
    2. 移动文件对话框,选择目录。
    3. 单击确定,完成实时计算元表的移动。
    克隆实时计算元表
    1. 实时计算元表页面,将鼠标悬停在需要移动的实时计算元表后的图标,单击克隆
    2. 克隆实时计算元表对话框,配置参数。
    3. 单击确定
    删除实时计算元表
    说明 系统仅支持删除没有被实时计算任务引用的实时计算元表。
    1. 实时计算元表页面,将鼠标悬停在需删除的实时计算元表后的图标,单击删除
    2. 提示对话框,填写备注信息。
    3. 单击确定并提交,完成实时计算元表的删除。