目录
Ch1 实时流计算
Ch2 数据采集
Ch3 实现单节点流计算应用
Ch4 数据处理
Ch5 实时流计算的状态管理
Ch6 开源流计算框架
Ch7 当做不到实时
Ch8 数据传输
Ch9 数据存储
Ch10 服务治理和配置管理
Ch11 实时流计算应用案例
Ch1 实时流计算
大数据时代的新挑战:实时流计算
实时流计算使用场景
实时流数据的特点
实时流计算系统架构
Ch2 数据采集
设计数据采集的接口
使用 Spring Boot 实现数据采集服务器
BIO 与 NIO
NIO 和异步
使用 Netty 实现数据采集服务器
Ch3 实现单节点流计算应用
自己动手写实时流计算框架
CompletableFuture 方法与原理
采用 CompletableFuture 实现单节点流处理
流计算应用的性能调优
Ch4 数据处理
流计算到底在计算什么
流数据操作
时间维度聚合特征计算
关联图谱特征计算
事件序列分析
模型学习和预测
Ch5 实时流计算的状态管理
流的状态
采用 Redis 实现流信息状态管理
采用 Apache Ignite 实现流信息状态管理
扩展为集群
Ch6 开源流计算框架
Apache Storm
Spark Streaming
Apache Samza
Apache Flink
Ch7 当做不到实时
做不到实时的原因
Lambda 架构
Kappa 架构与架构实例
Ch8 数据传输
消息中间件
Apache Kafka
RabbitMQ
Apache Camel
Ch9 数据存储
存储的设计原则
点查询
Ad-Hoc 查询
离线分析
关系型数据库查询
Ch10 服务治理和配置管理
服务治理
面向配置编程
动态配置
将前端配置与后端服务配置隔离开
Ch11 实时流计算应用案例
实时流数据特征提取引擎
使用 Flink 实现风控引擎