见知乎文章https://zhuanlan.zhihu.com/p/617706691[https://zhuanlan.zhihu.com/p...
本文是阅读了Etcd client v3官方代码后,结合个人理解做的一些整理,有理解不正确不到位的地方还望指正~ Etcd版本信息 代码库:ht...
Raft是一种分布式一致性算法,相比于Paxos,它更容易理解和实现,效率也相当。Raft 将一致性的关键元素分成几部分,如leader选举、日...
InfluxDB 概念:InfluxDB是一种时序数据库:按时间顺序写入数据,并按照一定时间策略保留数据的数据库 1. Database: 数据...
1. 目的 为了实现flink任务的容灾与恢复 2. 概念以及实现原理 状态state:指算子或算子并发中的状态数据,与数据流有关系,随流入...
DataStream 1. map/flatMap MapFunction<T, O> 输入一个元素,输出一个元素,其中包含了变换逻辑 Rich...
1. Connect DataStream有两个connect方法: 前者是与普通DataStream连接,多用于把两个流合并;后者是与一个Br...
DataStream上游算子向下游算子发送数据的不同方式: forward (默认) the output elements are forwa...
定义与作用 官方定义:A Watermark tells operators that no elements with a timestamp...