如下,请问机器学习PAI的这个问题怎么解决?

请教一个flinksql 问题,要求是每来一条输出一次结果,计算一个数值按照group id,现在发现我一次发多条数据的时候,可能会触发一起计算,不是一条条的,有啥办法处理嘛

展开
收起
乐天香橙派 2023-11-14 10:37:36 77 发布于江西 分享
分享
版权
举报
1 条回答
写回答
取消 提交回答
  • 在Flink SQL中,可以使用窗口函数(Window Function)来实现每条数据单独计算的需求。具体来说,可以使用ROW_NUMBER()窗口函数为每个分组内的数据分配一个唯一的序号,然后根据这个序号进行计算。

    以下是一个示例:

    SELECT
      id,
      group_id,
      value,
      -- 使用ROW_NUMBER()窗口函数为每个分组内的数据分配一个唯一的序号
      ROW_NUMBER() OVER (PARTITION BY group_id ORDER BY id) AS row_num,
      -- 根据序号计算结果
      value * row_num AS result
    FROM
      your_table;
    

    这样,当有新的数据到来时,Flink会为每个分组内的数据分配一个唯一的序号,并根据这个序号进行计算,从而实现每条数据单独计算的需求。

    2023-11-30 13:48:00 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论

人工智能平台 PAI(Platform for AI,原机器学习平台PAI)是面向开发者和企业的机器学习/深度学习工程平台,提供包含数据标注、模型构建、模型训练、模型部署、推理优化在内的AI开发全链路服务,内置140+种优化算法,具备丰富的行业场景插件,为用户提供低门槛、高性能的云原生AI工程化能力。

还有其他疑问?
咨询AI助理
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等