Spark Streaming 源码详解
原地址
本系列内容适用范围:* 2015.12.05 update, Spark 1.6 全系列 √ (1.6.0-preview,尚未正式发布)
* 2015.11.09 update, Spark 1.5 全系列 √ (1.5.0, 1.5.1, 1.5.2)
* 2015.07.15 update, Spark 1.4 全系列 √ (1.4.0, 1.4.1)
* 2015.04.17 update, Spark 1.3 全系列 √ (1.3.0, 1.3.1)
- 概述
- 0.1 Spark Streaming 实现思路与模块概述
- 模块 1:DAG 静态定义
- 1.1 DStream, DStreamGraph 详解
- 1.2 DStream 生成 RDD 实例详解
- 模块 2:Job 动态生成
- 2.1 JobScheduler, Job, JobSet 详解
- 2.2 JobGenerator 详解
- 模块 3:数据产生与导入
- 3.1 Receiver 分发详解
- 3.2 Receiver, ReceiverSupervisor, BlockGenerator, ReceivedBlockHandler 详解
- 3.3 ReceiverTraker, ReceivedBlockTracker 详解
- 模块 4:长时容错
预计 12.13
4.1 Executor 端长时容错详解预计 12.13
4.2 Driver 端长时容错详解
- StreamingContext
预计 12.20
5.1 StreamingContext 详解
转载于:https://www.cnblogs.com/shexinwei/p/5042515.html
Spark Streaming 源码详解相关推荐
- 第43课: Spark 1.6 RPC内幕解密:运行机制、源码详解、Netty与Akka等
第43课: Spark 1.6 RPC内幕解密:运行机制.源码详解.Netty与Akka等 Spark 1.6推出了以RpcEnv.RPCEndpoint.RPCEndpointRef为核心的新型架构 ...
- 【Live555】live555源码详解(九):ServerMediaSession、ServerMediaSubsession、live555MediaServer
[Live555]live555源码详解系列笔记 继承协作关系图 下面红色表示本博客将要介绍的三个类所在的位置: ServerMediaSession.ServerMediaSubsession.Dy ...
- 【Live555】live555源码详解系列笔记
[Live555]liveMedia下载.配置.编译.安装.基本概念 [Live555]live555源码详解(一):BasicUsageEnvironment.UsageEnvironment [L ...
- 【Live555】live555源码详解(八):testRTSPClient
[Live555]live555源码详解系列笔记 继承协作关系图 下面红色表示本博客将要介绍的testRTSPClient实现的三个类所在的位置: ourRTSPClient.StreamClient ...
- 【Live555】live555源码详解(七):GenericMediaServer、RTSPServer、RTSPClient
[Live555]live555源码详解系列笔记 继承协作关系图 下面红色表示本博客将要介绍的三个类所在的位置: GenericMediaServer.RTSPServer.RTSPClient 14 ...
- 【Live555】live555源码详解(六):FramedSource、RTPSource、RTPSink
[Live555]live555源码详解系列笔记 继承协作关系图 下面红色表示本博客将要介绍的三个类所在的位置: FramedSource.RTPSource.RTPSink 11.FramedSou ...
- 【Live555】live555源码详解(五):MediaSource、MediaSink、MediaSession、MediaSubsession
[Live555]live555源码详解系列笔记 继承协作关系图 下面红色表示本博客将要介绍的四个类所在的位置: MediaSource.MediaSink.MediaSession.MediaSub ...
- 【Live555】live555源码详解(四):Medium媒体基础类
[Live555]live555源码详解系列笔记 7.Media Medai所依赖关系图 依赖Medai关系图 Media和UsageEnvironment关联图
- 【Live555】live555源码详解(二):BasicHashTable、DelayQueue、HandlerSet
[Live555]live555源码详解系列笔记 3.BasicHashTable 哈希表 协作图: 3.1 BasicHashTable BasicHashTable 继承自 HashTable 重 ...
最新文章
- jqmobi快速开始(翻译)
- [转载] 晓说——第2期:汉人无音乐都怪老祖宗
- ActiveMQ_使用经验
- osqa java_从LSM-Tree、COLA-Tree谈到StackOverflow、OSQA(召唤前端)
- MySql DATE_FORMAT函数用法
- java date linux,Java中Date,SimpleDateFormat
- python利用有道词典翻译_使用Python从有道词典网页获取单词翻译
- java dom cdata_java – 通过DOM解析器从XML处理CDATA
- es统计有多少个分组_ES 24 - 如何通过Elasticsearch进行聚合检索 (分组统计)
- 耳机的L和R是什么意思?
- power bi报表服务器_如何将Power BI Report Server报表嵌入ASP.Net Web应用程序
- (二)java版电子商务spring cloud分布式微服务b2b2c社交电商-Spring Boot配置文件详解...
- 软路由cpu性能跑分
- 解决发送push的emoji表情的实用方案
- Android 使用讯飞语音SDK
- 欧姆龙PLC分频电路
- 浅谈:Java和C语言各自的学习难度
- js发布订阅原理,代码解析
- P3939 数颜色 (权值线段树)
- HanLP中人名识别分析
热门文章
- IDEA导入Git中项目
- python多线程提高速度_Python3如何使用多线程升程序运行速度
- python如何设置画布开始位置_如何设置亚马逊站内广告?亚马逊自动广告手动广告都在什么位置?...
- Leetcode 208:实现Trie(前缀树)
- 目标检测(二十一)--FCN
- C语言——指针篇(四)多维数组和多维指针(内含数组指针和指针数组笔记)
- 金蝶显示服务器不是有效,金蝶 服务器不是有效的 请重新设置
- 适配器模式在 Java 日志中的应用
- 他山之石,可以攻玉--从伪代码的角度来理解排序算法
- USB杀手上Indigogo众筹 可以毁坏电脑USB接口