发简信
IP属地：四川
-
金字塔结构学习过程记录
时间过得真快，马上要33岁了。从生活还是工作上，我感觉都是个偏被动的人。眼瞅着日子一天天过去，自己的状态和几年前差不多，内心急得团团转。 昨天和...
-
动手写蚁群算法（上）基本原理一、什么是蚁群算法 蚁群算法是一种启发式算法，灵感来自于真实世界蚁群的觅食行为，它由Marco Dorigo于1992年在他的博士论文中提出。单...
-
Flink StateFunction 初识一、概要 Flink 的Stateful Function 2.0 也已经出来一段时间了，不清楚它的用途适用场景。本篇会有Stateful Fu...
-
记录一次三方配额事件及思考一、故事背景 最近负责的业务由于三方配额不够，需要购买配额。问题来了，买多少配额合适？下图是目前的调用关系。由于是关于IOT的业务，其中老的实现...
-
Flink POJO类型ValueState演化原理剖析
一、起因 最近使用Flink(1.8.1)遇到一个问题，ValueState中数据结构的一个字段类型在开发的时候定义的是int类型，但是实际上应...
-
Flink应用高可用方案探索一、为什么要做高可用 由于依赖Flink应用A下游服务非常重要，对应用A所提供数据的实时性、可靠性要求比较高。所以对应用A进行了高可用改造，运行...
-
Hbase scanner逆向查询原理（上）客户端一、背景 一直听说hbase scanner的逆向查询比正向查询要慢很多，而且多消耗了很多资源。原因在哪里，并没有找到明确的答案。分为客户端和服...
-
Flink中数量窗口增加等待时间
Flink窗口可以分为时间维度窗口和数据量窗口。其中时间维度窗口又可分为ProcessingTime和EventTime。一般情况下以时间作为窗...