开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

某人的每一张抓拍,在同一摄像机下前后n秒抓拍的其他人,定义为一次同行。同行次数超过阈值即为同行人。

某人的每一张抓拍,在同一摄像机下前后n秒抓拍的其他人,定义为一次同行。同行次数超过阈值即为同行人。 请问这个用Flink CEP 可以实现吗?

展开
收起
云上静思 2022-07-01 11:23:34 1415 0
2 条回答
写回答
取消 提交回答
  • 人流量大了很困难吧?

    2022-07-02 09:06:29
    赞同 展开评论 打赏
  • 提供一个思路,你把它分成两个流,然后再join 。以其中一个A为主,关联另外一个B,条件是A.time+-n 秒=B.time。

    此答案来自钉钉群“【2】Apache Flink China 社区”

    2022-07-01 12:32:46
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关电子书

更多
千里之外,洞悉风险 立即下载
漏洞与数据的奇点临近 立即下载
一起来试验 保险箱的脆弱面 立即下载