- Flink支持两种划分窗口的方式,按照time和count。如果根据时间划分窗口,那么它就是一个time-window如果根据数据划分窗口,那么它就是一个count-window。
Flink在做计算的过程中经常需要存储中间状态,来避免数据丢失和状态恢复。选择的状态存储策略不同,会影响状态持久化如何和 checkpoint 交互。
简单配置就可以轻松实现,首先需要设置Sink组,同一个Sink组内有多个子Sink,不同Sink之间可以配置成负载均衡或者故障转移。
Source发送的Event通过Channel选择器来选择以哪种方式写入到Channel 中,Flume提供三种类型Channel选择器,分别是复制、复用和自定义选择器。
就绪态: 进程已经具备执行的一切条件,正在等待分配 CPU 的处理时间。执行态: 该进程正在占用 CPU 运行。等待态: 进程因不具备某些执行条件而暂时无法继续执行的状态。