发简信
IP属地：北京
-
java判空的一些实用Utils以及包名
1.ObjectUtils.isEmpty(Object object) 包名：org.springframework.util 可以用来判断object是否是null，如果...
-
flink 问题总结（9）registerProcessingTimeTimer 定时器疑问(包括源码阅读)
请移步 flink问题总结目录 (不断更新中)[https://www.jianshu.com/p/ef5618429d24]姐妹篇 registerEventTimeTim...
-
Flink状态的缩放（rescale）与键组（Key Group）设计前言 在之前那篇讲解Flink Timer的文章里，我曾经用三言两语简单解释了Key Group和KeyGroupRange的概念。实际上，Key Group是Flink状态...
-
Flink Timer（定时器）机制与其具体实现Timer简介 Timer（定时器）是Flink Streaming API提供的用于感知并利用处理时间/事件时间变化的机制。Ververica blog上给出的描述如下： ...
-
flink 自定义触发器 定时或达到数量触发flink 触发器 触发器确定窗口(由窗口分配程序形成)何时准备由窗口函数处理。每个WindowAssigner都带有一个默认触发器。如果默认触发器不适合需求，我们就需要自定...
-
【Flink 精选】阐述 Watermark 机制，剖析 Watermark 的产生和传递流程本文阐述 Flink 的事件时间和 Watermark 机制，剖析 Watermark 产生和传递的流程。 1 Event time 和 Watermark 的关系 1.1 ...
