使用postgre的窗口函数row_number, 分块后选择需要自己的行 例：获取分组中的最大数据，从table1表中获取以cloumn1字段作为分组，每组中cloum2字段最大的行数据 select * from( select * ,row_number() over (partition b ...
分类：
其他好文 时间：
2020-05-15 19:58:59
阅读次数：
259
有状态和无状态 无状态：仅限对收集周期内数据进行处理 有状态：将本次收集周期与前面的所有收集周期获得的数据统一进行处理，两个周期内的数据合并过程类似于SparkSQL中自定义聚合函数的buffer。 窗口函数 window operations可以设置窗口的大小和华东窗口的间隔来动态的获取当前Str ...
分类：
其他好文 时间：
2020-05-12 15:22:08
阅读次数：
59
rank() 跳跃排序，即如果第二名和第三名分数一样，则二三都是2，第四名为4dense_rank() 连续排序，二三同上，第四名为3，即名次连续row_number() 无重复值排序，直接为1 2 3 4，不分是否分数相等 50题第19题 https://yq.aliyun.com/article ...
分类：
其他好文 时间：
2020-05-08 18:22:16
阅读次数：
47
1、新建一个窗口算子需指定两个窗口组件 1）窗口分配器（window assigner），决定如何划分窗口，比如每5秒一个窗口（左闭右开区间），按照事件时间或者处理时间划分； 2）窗口函数，决定如何处理窗口中的元素 2、DataStream API 中的多种内置窗口分配器 1）滚动窗口（Tumbli ...
分类：
其他好文 时间：
2020-04-19 22:13:10
阅读次数：
81
表数据如下 select * from business; business.name business.orderdate business.cost jack 2017-01-01 10 tony 2017-01-02 15 jack 2017-02-03 23 tony 2017-01-04 ...
分类：
其他好文 时间：
2020-04-19 19:32:42
阅读次数：
61
[toc] 卷积 说到卷积，就不得不提互相关$cross orrelation$。卷积实质就是一种互相关运算，只不过要在进行互相关运算前，要把$kernal$上下左右进行翻转。即$cross correlation$的计算顺序是从左到右，从上到下，而$convolution$的顺序是从右到左，从下到 ...
分类：
其他好文 时间：
2020-04-19 17:44:30
阅读次数：
256
前言：在某些应用场景中，我们经常会遇到一些排名的问题，比如按成绩或年龄排名。排名也有多种排名方式，如直接排名、分组排名，排名有间隔或排名无间隔等等，这篇文章将总结几种MySQL中常见的排名问题。创建测试表createtablescores_tb(idintauto_incrementprimarykey,xuehaointnotnull,scoreintnotnull)ENGINE=InnoDBD
分类：
数据库 时间：
2020-04-17 18:38:10
阅读次数：
159
函数功能 该函数创建一个具有扩展风格的层叠式窗口、弹出式窗口或子窗口 函数参数 dwExStyle 指定窗口的扩展风格。该参数可以是下列值： WS_EX_NODRAG:防止窗口被移动 WS_EX_ACCEPTFILES：指定以该风格创建的窗口接受一个拖拽文件。 WS_EX_APPWINDOW：当窗口 ...
1、什么是触发器触发器决定了一个窗口何时可以被窗口函数处理(条件满足时触发并发出信号) 每一个WindowAssigner都有一个默认的触发器，如果默认的触发器不能满足你的需要，你可以通过调用trigger(...)来指定一个自定义的触发器 触发器有5个方法来允许触发器处理不同的事件(Trigger ...
分类：
其他好文 时间：
2020-04-05 18:15:44
阅读次数：
208
背景这两年互联网行业掀着一股新风，总是听着各种高大上的新名词。大数据、人工智能、物联网、机器学习、商业智能、智能预警啊等等。以前的系统，做数据可视化，信息管理，流程控制。现在业务已经不仅仅满足于这种简单的管理和控制了。数据可视化分析，大数据信息挖掘，统计预测，建模仿真，智能控制成了各种业务的追求。“所有一切如泪水般消失在时间之中，时间正在死去“，以前我们利用互联网解决现实的问题。现在我们已经不满足
分类：
数据库 时间：
2020-03-06 10:32:08
阅读次数：
385
