第1章SparkStreaming應用概述······11.1SparkStreaming應用案例·······2
1.2 SparkStreaming應用剖析·····13
第2章SparkStreaming基本原理····15
2.1 SparkCore簡介··················16
2.2SparkStreaming設計思想·····26
2.3SparkStreaming整體架構·····30
2.4編程接口·························33
第3章SparkStreaming運行流程詳解·············39
3.1從StreamingContext的初始化到啟動··········40
3.2數據接收·························54
3.3數據處理·························91
3.4數據清理························115
3.5容錯機制························127
3.5.1容錯原理·························128
3.5.2Driver容錯機制·················152
3.5.3Executor容錯機制··············161
3.6NoReceiver方式···············167
3.7輸出不重復·····················175
3.8消費速率的動態控制·········176
3.9狀態操作························189
3.10窗口操作·······················212
3.11頁面展示·······················216
3.12SparkStreaming應用程序的停止··········227
第4章SparkStreaming性能調優機制···········237
4.1并行度解析·····················238
4.1.1數據接收的并行度·············238
4.1.2數據處理的并行度·············240
4.2內存······························240
4.3序列化···························240
4.4BatchInterval···················241
4.5Task·······························242
4.6JVMGC·························242
第5章Spark2.0中的流計算··········245
5.1連續應用程序··················246
5.2無邊界表unboundedtable····248
5.3增量輸出模式··················249
5.4API簡化··························250
5.5其他改進························250
3dWoo書號： 46551
│加到我的最愛