《分布式计算系统》示例代码

徐辰 编著 《分布式计算系统》 2022年9月

第2章 Hadoop文件系统

1. 写文件
2. 读文件

第3章 批处理系统MapReduce

1. 词频统计
2. 关系表自然连接及其优化
3. 网页链接排名
4. K均值聚类

第4章 批处理系统Spark

1. 词频统计
2. 关系表自然连接及其优化
3. 网页链接排名
4. K均值聚类
5. 检查点

第7章 流计算系统Storm

1. 词频统计
2. 支持容错的词频统计
3. 简化的窗口操作
4. 异常检测

第8章 流计算系统Spark Streaming

1. 按批词频统计
2. 全局词频统计
3. 窗口操作
4. 异常检测

第10章 批流融合系统Flink

1. 词频统计
2. 斐波那契数列生成
3. 整数求和*
4. 支持容错的词频统计

第11章 图处理系统Giraph

1. 连通分量
2. 单源最短路径
3. 网页链接排名
4. K均值聚类