Flink1.13架构全集| 一文带你由浅入深精通Flink方方面面（四）CEP篇

对于你喜欢的事想去做的事,你必须付出百分之一千的努力你知道这一路可能会有很多困难，会有坚持不下去想要放弃的时候也有时候，你不一定会得到你想要的结果,但你—定要相...

Flink1.13架构全集| 一文带你由浅入深精通Flink方方面面（三）SQL篇

哈喽各位，本章主要写的是FlinkSQL也是Flink章节的倒数第二篇了，最后还有一篇FlinkCEP，稍后会出，耐心关注哦！好了，进入正题！！！！

Flink1.13架构全集| 一文带你由浅入深精通Flink方方面面（二）

之前所介绍的流处理API，无论是基本的转换、聚合，还是更为复杂的窗口操作，其实都是基于DataStream进行转换的；所以可以统称为DataStream API...

Flink1.13架构全集| 一文带你由浅入深精通Flink方方面面

导读：Flink是由德国几所大学发起的的学术项目，后来不断发展壮大，并于2014年末成为Apache顶级项目。Flink如何在流处理中多得王者地位？带着问题在文...

【源码解读】| LiveListenerBus源码解读

异步事件列队主要由LinkedBlockingQueue[SparkListenerEvent] 构建，默认大小为10000

浅谈 Apache Doris FE 处理查询 SQL 源码解析

在使用 Apache Doris 时，我们可以通过 Apache Doris FE Web 页面或者 Mysql 协议执行 SQL 语句，但是对于 Apache...

【思考】数据资产管理痛点以及解决思路

元数据作为记录数据的数据，随着公司数据资产的增加，需要对其进行有效的管理，从而能够快速获取到数据的相关信息并进行使用。

Doris FE源码解读系列之源码编译踩坑！！！

最近在学习Doris FE源码，按照Doris官网开发者手册下载源码时，出现了很多问题，比如Jar包无法加载、编译项目报错、Thrift 插件无法引用等等，导致...

【源码解读】|SparkEnv源码解读

在「SparkContext.scala」 中创建，老版本参数中还有actorsystem

【万字长文】Doris FE启动流程源码详细解析

Apache Doris是一个现代化的MPP分析型数据库产品。仅需亚秒级响应时间即可获得查询结果，有效地支持实时数据分析。Apache Doris的分布式架构非...

【源码解读】|SparkContext源码解读

Spark配置类，配置已键值对形式存储，封装了一个ConcurrentHashMap类实例settings用于存储Spark的配置信息。

【万字长文】Flink cdc源码精讲(推荐收藏)

上面内容主要是以构建source所需要的参数为主,具体我们进入到DebeziumSourceFunction中看看具体实现

【万字长文】Hbase最全知识点整理（建议收藏）

Zookeeper： Master 的高可用、RegionServer 的监控、元数据的入口以及集群配置的维护等

【万字长文】HDFS最全知识点整理（建议收藏）

1）跟NN通信查询元数据(block所在的DN的节点)，找到文件块所在的DN的服务器。2）挑选一台DN（就近原则，然后随机）服务器，请求建立socket流。3）...

数据分析中常见的"数据陷阱" !!!

做数据分析的人相信对辛普森悖论(Simpson's Paradox)早已耳熟能详，所谓辛普森悖论，通俗来说就是观测者在观测分组指标时得到了性质 A，但在汇总指标...

【万字长文】Spark最全知识点整理（内含脑图）

Spark有以下四种部署方式，分别是：Local，Standalone，Yarn，Mesos

【万字长文】Kafka最全知识点整理（建议收藏）

Kafka是一个开源的高吞吐量的分布式消息中间件，对比于其他 1) 缓冲和削峰：上游数据时有突发流量，下游可能扛不住，或者下游没有足够多的机器来保证冗余，kaf...

【万字长文】数仓最全知识点整理（建议收藏）

数据仓库 Data Warehouse，是为企业所决策制定过程，提供所有支持类型的数据集合。用于分析性报告和决策支持。数仓是一个面向主题、集成的、相对稳定、反映...

浅谈基于 Zookeeper 实现分布式锁对 Maxwell 完成高可用

【Kafka源码】万字长文详解Kafka网络模型、副本机制

kafka 是业界消息中间件之楷模，他从网络设计、副本同步机制设计的很优秀，业界也很多公司都使用了 kafka，当初我在腾讯的内部后端 serve 有些场景也是...