首页
学习
活动
专区
工具
TVP
发布

菩提树下的杨过

专栏作者
1167
文章
1498594
阅读量
96
订阅数
flink 1.11.2 学习笔记(5)-处理消息延时/乱序的三种机制
* 按时间顺序发生的数据1 -> 2,本来应该是1先发送,1先到达,但是在1发送过程中,因为网络延时之类的原因,导致1反而到达晚了,变成2先到达,也就造成所谓的接收乱序;
菩提树下的杨过
2021-09-09
1K0
flink 1.11.2 学习笔记(5)-lambda表达式的使用问题
如果idea环境,使用jdk1.8的话,可能会智能提示,让你把24行改与lambda表达式,看上去更清爽一些:
菩提树下的杨过
2021-03-12
8030
flink 1.11.2 学习笔记(4)-状态示例
接上节继续,今天学习Flink中状态的使用。数据处理的过程中,对当前数据的处理,有时候要依赖前一条数据的值,这种被称为“有状态”的计算。
菩提树下的杨过
2020-12-22
1K0
flink 1.11.2 学习笔记(3)-统计窗口window
接上节继续,通常在做数据分析时需要指定时间范围,比如:"每天凌晨1点统计前一天的订单量" 或者 "每个整点统计前24小时的总发货量"。这个统计时间段,就称为统计窗口。Flink中支持多种Window统计,今天介绍二种常见的窗口:TumbingWindow及SlidingWindow。
菩提树下的杨过
2020-12-22
1.2K0
flink 1.11.2 学习笔记(2)-Source/Transform/Sink
从上一节wordcount的示例可以看到,flink的处理过程分为下面3个步骤:
菩提树下的杨过
2020-11-24
1.1K0
spring boot + embed tomcat + standalone jar的内存泄露问题
前一阵遇到了一个很坑的内存泄露问题,记录于此: 有个项目采用spring cloud重构后,部署到线上(其中有一个接口,大概每天调用量在1千万次左右),发现zabbix监控里,linux的可用内存一直
菩提树下的杨过
2018-01-18
1.3K0
没有更多了
社区活动
Python精品学习库
代码在线跑,知识轻松学
【玩转EdgeOne】征文进行中
限时免费体验,发文即有奖~
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·干货材料·成员作品·最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档