开发者社区 > 大数据与机器学习 > 人工智能平台PAI > 正文

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

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

展开
收起
乐天香橙派 2023-11-14 10:37:36 63 0
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
    赞同 展开评论 打赏

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

相关产品

  • 人工智能平台 PAI
  • 热门讨论

    热门文章

    相关电子书

    更多
    微博机器学习平台架构和实践 立即下载
    机器学习及人机交互实战 立即下载
    大数据与机器学习支撑的个性化大屏 立即下载