反馈已提交

网络繁忙

分组汇总(实时任务)

  • 文档创建者:Wendy123456
  • 历史版本:6
  • 最近更新:Richard.Guo 于 2025-08-29
  • icon提示:

    产品注册版本为「v5.0共创版」时,才能使用数据开发-实时任务:

    1) 如需申请免费试用或增购功能点,请填写链接:实时任务意向使用申请表

    2) 如需了解更多实时任务详细信息,可联系技术支持(技术支持联系方式:前往「服务」,选择「在线支持」、电话「400-811-8890」)。

    1. 概述

    1.1 版本

    FineDataLink 版本功能变动
    5.0.0.1-
    5.0.1.5实时任务中若使用 WebSocket输入MQTT输入IBM MQ输入Pulsar输入,不能再使用分组汇总节点

    1.2 应用场景

    数据开发-实时任务中,希望能做简单的汇总聚合,比如求和、平均值、记录个数。

    1.3 功能简介

    新增「分组汇总算子,支持对数据流进行实时聚合计算。如下图所示:

    23.png

    1.4 注意事项

    1)需要注册实时高级算子包功能点。

    2)需要配置 Flink引擎

    3)5.0.1.5 及之后版本,实时任务中若使用 WebSocket输入MQTT输入IBM MQ输入Pulsar输入,不能再使用分组汇总节点

    2. 操作步骤

    本章使用一个简单示例,讲解「分组汇总算子如何在数据开发-实时任务中使用。

    2.1 新建实时任务

    进入 FineDataLink 工程,点击数据开发>实时任务,新建一个实时任务。如下图所示:

    14.png

    2.2 数据输入

    拖入「CDC输入算子,设置待处理的表数据。如下图所示:

    15.png

    点击「数据预览,如下图所示:

    1749020761171520.png

    2.3 分组汇总

    拖入「分组汇总」算子,根据 date 字段对 num 字段进行分组汇总。如下图所示:

    16.png

    点击「数据预览,如下图所示:

    1749020702738910.png

    设置项
    说明
    维度分组参考数据开发-定时任务中 分组汇总 算子的维度分组设置项说明
    指标汇总
    与数据开发-定时任务中 分组汇总 算子的指标汇总设置项大致相同,不同点如下:
    • 当字段为「文本类型时,提供去重计数、记录个数;不提供字符串去重拼接、第一项、最后一项

    • 当字段为「数值类型时,提供求和、求平均、求最大值、求最小值、去重计数、记录个数、求方差、求标准差、求中位数

    • 当字段为「时间类型时,提供去重计数、记录个数、最早时间、最晚时间

    2.4 数据输出

    拖入「DB表输出」算子,将数据输出。如下图所示:

    1749022076631281.png

    2.5 启动任务

    点击右上角的「启动按钮,启动实时任务。启动后,界面如下图所示:

    20.png





    附件列表


    主题: 数据开发-实时任务
    • 有帮助
    • 没帮助
    • 只是浏览
    中文(简体)

    鼠标选中内容,快速反馈问题

    鼠标选中存在疑惑的内容,即可快速反馈问题,我们将会跟进处理。

    不再提示

    10s后关闭



    AI

    联系我们
    在线支持
    获取专业技术支持,快速帮助您解决问题
    工作日9:00-12:00,13:30-17:30在线
    页面反馈
    针对当前网页的建议、问题反馈
    售前咨询
    采购需求/获取报价/预约演示
    或拨打: 400-811-8890 转1
    qr
    热线电话
    咨询/故障救援热线:400-811-8890转2
    总裁办24H投诉:17312781526
    提交页面反馈
    仅适用于当前网页的意见收集,帆软产品问题请在 问答板块提问前往服务平台 获取技术支持