flink 1.11.2 学习笔记(1)-wordCount
一、pom依赖 View Code 二、WordCount(批处理版本) View Code 注：数据文件/Users/jimmy/Downloads/word.txt的位置，大家可根据实际情况调整，该文件的内容 ...
原文：flink 1.11.2 学习笔记(5)-处理消息延时/乱序的三种机制
在实时数据处理的场景中，数据的到达延时或乱序是经常遇到的问题，比如： 按时间顺序发生的数据 gt ，本来应该是 先发送， 先到达，但是在 发送过程中，因为网络延时之类的原因，导致 反而到达晚了，变成 先到达，也就造成所谓的接收乱序 发送方本身就延时了，比如：事实上按 gt 产生的数据 ，发送方如果是多线程发送数据，可能造成 先发， 后发，中间网络传输就算没有延时，也会导致接收到时已经乱序 有一些比 ...
2021-09-05 17:28 0 843 推荐指数：
相关推荐
flink 1.11.2 学习笔记(3)-统计窗口window
接上节继续，通常在做数据分析时需要指定时间范围，比如："每天凌晨1点统计前一天的订单量" 或者 "每个整点统计前24小时的总发货量"。这个统计时间段，就称为统计窗口。Flink中支持多种Window统计，今天介绍二种常见的窗口：TumbingWindow及SlidingWindow ...
flink 1.11.2 学习笔记(5)-lambda表达式的使用问题
flink的api，提供了流畅的链式编程写法，写起来行云流水，感受一下： SingleOutputStreamOperator<Tuple3<String, Integer, String>> counts = env //设置并行度1，方便观察输出 ...
DELPHI中的消息处理机制（三种消息处理方法的比较，如何截断消息）
DELPHI中的消息处理机制 Delphi是Borland公司提供的一种全新的WINDOWS编程开发工具。由于它采用了具有弹性的和可重用的面向对象Pascal(object-orientedpascal)语言，并有强大的数据库引擎(BDE)，快速的代码编译器，同时又提供了众多出色的构件。受到广大 ...
Flink如何巧用WaterMark机制解决乱序问题
问：数据工程师最期望数据怎么来？ 答：按顺序来。 MapReduce当初能用起来，就是因为Map阶段对所有数据都进行排序了，后面的Reduce阶段就可以直接用排序好的数据了。 批处理的时候因为数据已经落地了，咱可以慢慢排序。但是流式数据都是一条一条过来的，这个时候数据到达的时间和出发时 ...
「学习笔记」对实模式/保护模式的三种访问内存机制的理解
假设x86处理器执行以下的指令 主要讨论实模式和保护模式：这包括16位模式即实模式，32位模式即保护模式，以及32位模式下的16位兼容模式（首先需要明确的是保护模式有着不同的内存访问机制，简单地说就是传统的涉及段的几个寄存器如CS,DS,ES,SS等被解释为不同的内容——实 ...
ActiveMQ笔记(6)：消息延时投递
在开发业务系统时，某些业务场景需要消息定时发送或延时发送（类似：飞信的短信定时发送需求），这时候就需要用到activemq的消息延时投递，详细的文档可参考官网说明，本文只介绍二种常用的用法： 注：本文采用spring的JmsTemplate来发送消息 步骤1、首先要修改activemq.xml ...
flink1.11.2安装使用
（一） flink 1.11.2 下载地址 ： https://mirrors.tuna.tsinghua.edu.cn/apache/flink/flink-1.11.2/python ...