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

大佬们,想问个cep的场景,监控用户的轨迹,用户的经纬度会上传到后台。我怎么用cep判断一定的时间间

大佬们,想问个cep的场景,监控用户的轨迹,用户的经纬度会上传到后台。我怎么用cep判断一定的时间间隔内,用户行驶的距离超过某个值,并且数据一直有上传,没有关闭定位啥的。 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

展开
收起
黄一刀 2019-12-09 17:54:57 3167 0
2 条回答
写回答
取消 提交回答
  • 距离可以在where中做下判断吧,如果关闭定位数据不在上传,那么整个模式匹配失败,之前的事件就会被清理掉

    2019-12-09 17:56:52
    赞同 展开评论 打赏
  • 可以分成两部分, 一定时间内的距离可以用 cep 的 within time, 关闭定位就是没有数据,可以单独处理一下,比如 process function 加个 timer

    2019-12-09 17:55:38
    赞同 展开评论 打赏

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

相关电子书

更多
十分钟上线-使用函数计算构建支付宝小程序服务 立即下载
FLINK在大规模实时无效广告流量检测中的应用 立即下载
动态、高效,蚂蚁动态卡片的内核逻辑 立即下载