更新时间:2024-11-29 GMT+08:00

添加窗口变量

操作场景

业务管理人员可定义窗口变量,通过窗口变量查询Redis流表数据用于后续规则计算。一个窗口变量对应一个Flink作业。

操作步骤

  1. 参考访问RTD WebUI界面,使用业务用户登录RTD WebUI管理界面,选择要操作的租户。
  2. 选择“业务管理 > 变量&规则配置 > 窗口变量”。
  3. 单击“新增”,参见以下表格设置窗口变量的相关属性参数。

    表1 窗口变量参数一览表

    参数名

    说明

    事件源类型

    选择变量所属事件源类型。

    查询主键

    根据事件源类型勾选主键。

    说明:
    • 查询主键的含义是指窗口变量从Redis数据库中读取的Key值,格式为“${前缀}:${窗口变量名称}_${主键1的值}_${主键2的值}_... ...”。在勾选主键时注意先后顺序。例如先勾选PID再勾选UID,则查询主键为${前缀}:${变量名称}_${PID}_${UID}。
    • 主键的勾选顺序需与对应作业勾选的主键顺序一致。

    名称

    设置窗口变量名称。必须以wv_开始,包括字母、数字、下划线,长度限制为4-30个字符。

    说明:

    窗口变量名称需要与作业SQL的concat的静态值一致。

    类型

    设置变量类型。可选string、long、integer、double。

    默认值

    根据变量类型设置变量默认值。

    redis集群

    选择变量所属Redis集群。

    是否批变量

    勾选为批变量,不勾选时为流变量。分别对应Flink的批作业和流作业。

    前缀

    数据在Redis数据库中的键值前缀。

    流/表

    选择变量读取的流/表。

    描述

    输入变量的描述信息。

  4. 参数设置完成后,单击“确认”,添加窗口变量。

    变量添加完成后,在窗口变量界面可以对创建的变量进行上/下线、编辑、删除等操作。具体操作请参考管理窗口变量