当前位置:   article > 正文

Flink SQL 实时大屏(实时查询存量数据-批转流)_flink能做实时查询么

flink能做实时查询么

          最近接到一个需求,关于flink实时大屏需求。每半小时展示历史每天当前半小时(每天00:00:00-00:30:00之间) 的数据的最大值最小值中位数上四分位数下四分位数

需求描述

  每半小时计算一次当前半点历史的数据的最大值最小值中位数上四分位数下四分位数。这里的历史数据需要详解一下: 

 如当前时间为16:30,只有30天历史数据。 则历史数据为: 今天的2021-08-10 16:00:00~16:30:00的数据、昨天的2021-08-09 16:00:00~16:30:00的数据、前天的2021-08-08 16:00:00~16:30:00的数据.... 2021-07-10 16:00:00~16:30:00的数据为历史的数据。

如图大屏展示效果:

 需求描述注意点:

     1)每分钟一条数据,是当前分钟数据量的一个count()值。

    如: 每分钟的数据量,每分钟一个点,00:00:00~00:01:00有一条数据。计算了当前分钟数据量。

数据例子 :           

  {'startTIme':'00:00:00','endTIme'
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/很楠不爱3/article/detail/480557
推荐阅读
相关标签
  

闽ICP备14008679号