博客

Apache Iceberg 数据湖核心实战:表格式、快照隔离、Schema 演进与湖仓一体

Iceberg通过三层元数据和快照隔离实现ACID、时间旅行与Schema演进,将对象存储转化为可管理的表格式。作为湖仓一体底座服务ODS/DWD层,与Doris/ClickHouse分工协作,避免数据重复存储。

神经蛙 发布于 2026-11-04

Apache Doris 实时数仓核心实战:MPP 架构、数据模型、导入与高并发查询

从"离线数仓查得慢、点查扛不住"的痛点切入,系统拆解 Apache Doris 的 MPP 架构(FE 元数据/查询规划 + BE 存储计算,MySQL 协议接入)、三种数据模型(Duplicate/Aggregate/Unique Key)与分区分桶策略,讲透 Stream Load/Routine Load/Broker Load 等导入方式与 Kafka/Flink 实时入仓链路,最后给出前缀索引、倒排索引、高并发点查、Colocate Join 等查询优化与十项生产避坑,补齐 ClickHouse 之外"高并发实时分析"的另一块拼图。

神经蛙 发布于 2026-10-30

ZooKeeper 核心原理与实战:ZNode 数据模型、Watch 机制、ZAB 协议与分布式协调

从"多台机器怎么协同"这个分布式老问题讲起,系统拆解 ZooKeeper 的四大支柱:树形 ZNode 数据模型与四种节点类型、一次性触发的 Watch 机制与羊群效应治理、Leader/Follower/Observer 集群分工与过半提交、ZAB 原子广播协议的崩溃恢复与消息广播两阶段,最后给出 Curator 分布式锁与选主的正确姿势、三大协调服务对比和生产避坑清单,补齐 Kafka、HBase 背后共同依赖的"协调层"拼图。

神经蛙 发布于 2026-10-23

Hive 离线数仓核心实战:HQL、分区分桶、文件格式与执行引擎选型

Kafka 让数据稳稳流起来,Spark/Flink 让数据算得又快又准,HBase 让海量数据存得下查得快,但"用 SQL 把 HDFS 上的海量数据按业务口径算成报表"这件事,最早靠手写 MapReduce——又慢又难维护。Hive 正是为此而生:把 HQL 翻译成分布式计算作业,让数据工程师用熟悉的 SQL 玩转 PB 级数据。本文拆解 Hive 的架构本质、内部表与外部表、分区与分桶的取舍、ORC/Parquet 文件格式选型、MapReduce→Tez→Spark 执行引擎演进,以及 MapJoin/CBO/向量化/数据倾斜等专属优化,并与 Kafka/Spark/Flink/HBa

神经蛙 发布于 2026-10-16

ClickHouse 列式存储与海量数据实时 OLAP 实战

从 OLTP 与 OLAP 的本质差异出发,深入讲解 ClickHouse 的列式存储、MergeTree 表引擎、分区与排序键、稀疏索引、向量化执行与物化视图等核心机制;对比行存与列存、MergeTree 与 Log 引擎、以及 ClickHouse 与 Elasticsearch/Doris/StarRocks 的适用场景;最后给出分片集群、写入去重、TTL、单表过大的生产避坑清单,是搭建实时分析平台的完整参考。

神经蛙 发布于 2026-10-13

HBase 核心原理与实战:LSM 树、Region 分裂、RowKey 设计与读写流程

Kafka 解决了数据怎么稳稳流起来,Spark/Flink 解决了数据怎么算得快算得准,但海量结构化数据怎么"存得下、查得快、随时横向扩展"——HBase 作为 Hadoop 生态的列式 NoSQL 承接这一角色。本文拆解其核心:稀疏多维的表模型、基于 LSM 树的写入链路、HMaster/RegionServer 架构与 Region 分裂、RowKey 反热点设计,以及布隆过滤器与 BlockCache 调优,最后给出生产避坑清单,与 Kafka/Spark/Flink 三篇拼成大数据平台的完整链路。

神经蛙 发布于 2026-10-07

Flink 核心原理与实战:时间语义、Watermark、状态管理与 Exactly-Once

从"微批为什么不够"讲起,系统拆解 Flink 的流处理内核:JobManager/TaskManager 架构与 Slot 并行模型、事件时间语义与 Watermark 乱序治理、三类窗口与迟到数据兜底、Keyed State 与 RocksDB 状态后端、基于 Barrier 的分布式快照如何实现端到端 Exactly-Once,最后对比三大流处理引擎并给出生产避坑清单,与 Kafka、Spark 两篇构成大数据流式链路的完整拼图。

神经蛙 发布于 2026-09-23

Spark 核心原理与实战:RDD、DAG 调度、Shuffle 与内存管理

从 MapReduce 的三大痛点讲起,系统拆解 Spark 的核心机制:RDD 五大特性与算子体系、宽窄依赖如何决定 DAG 的 Stage 划分、任务调度从 Job 到 Task 的完整链路、Shuffle 从 Hash 到 Sort 的演进与调优参数、统一内存管理的动态借用规则;再深入数据倾斜的定位与治理套路(加盐聚合、广播 Join),用一张表对比 MapReduce 与 Flink,最后给出生产环境避坑清单,是大数据工程师入门与复盘 Spark 的完整路线图。

神经蛙 发布于 2026-09-21

Kafka 核心原理与实战:分区、副本、消费组与精确一次语义

从"为什么需要消息队列"讲起,系统拆解 Kafka 的核心机制:Topic 与 Partition 如何支撑水平扩展与分区内有序,ISR 副本机制如何兼顾高可用与数据不丢,顺序写盘、零拷贝、页缓存、批量压缩如何成就百万级吞吐;深入生产者幂等与事务、消费者位移提交与再均衡、精确一次语义(EOS)的实现路径,并用一张表对比 Kafka 与 RabbitMQ/RocketMQ,最后给出生产环境避坑清单,是后端工程师入门与复盘 Kafka 的完整路线图。

神经蛙 发布于 2026-09-14