1.Flink中exactly once实现原理分析 生产者从kafka拉取数据以及消费者往kafka写数据都需要保证exactly once。目前flink中支持exactly once的so ...
一. 基本概念(https://blog.csdn.net/xianzhen376/article/details/89810958) 双流Join是Flink面试的高频问题。一般情况下说明以下几点 ...
1. 获取窗口迟到的数据 主要流程就是给迟到的数据打上标签，然后使用相应窗口流的实例调用sideOutputLateData(lateDataTag)，从而获得窗口迟到的数据，进而进行相关的计算 ...
1. Task的划分 在flink中，划分task的依据是发生shuffle（也叫redistrubute），或者是并行度发生变化 1. wordcount为例 ...
大致思路： canal去mysql拉取数据，放在canal所在的节点上，并且自身对外提供一个tcp服务，我们只要写一个连接该服务的客户端，去拉取数据并且指定往kafka写数据的格式就能达到以pr ...
1. 案例 方案一：使用ValueState结合HashSet实现 具体代码如下 ActivityCountAdv1 View Co ...
1. ProcessFunction ProcessFunction是一个低级的流处理操作，可以访问所有(非循环)流应用程序的基本构建块: event(流元素) state(容错，一 ...
1. 解析参数工具类（ParameterTool） 该类提供了从不同数据源读取和解析程序参数的简单实用方法，其解析args时，只能支持单只参数。 参数的输入格式 ...
1 练习讲解(此处自己没跑通，以后debug) 题目见flink---实时项目---day02 kafka中的数据，见day02的文档 GeoUtils ...