Spark Streaming源码分析 – DStream
A Discretized Stream (DStream), the basic abstraction in Spark Streaming, is a continuous sequence of RDDs (of the same type) representing ...
原文：Spark Streaming源码分析 – InputDStream
对于NetworkInputDStream而言，其实不是真正的流方式，将数据读出来后不是直接去处理，而是先写到blocks中，后面的RDD再从blocks中读取数据继续处理这就是一个将stream离散化的过程NetworkInputDStream就是封装了将数据从source中读出来，然后放到blocks里面去的逻辑 Receiver线程 还需要一个可以管理NetworkInputDStream， ...
2014-03-07 18:08 4 1796 推荐指数：
相关推荐
Spark Streaming源码分析 – Checkpoint
PersistenceStreaming没有做特别的事情，DStream最终还是以其中的每个RDD作为job进行调度的，所以persistence就以RDD为单位按照原先Spark的方式去做就可以了，不同的是Streaming是无限，需要考虑Clear的问题在clearMetadata时，在删除 ...
spark-streaming-kafka-0-10源码分析
转发请注明原创地址http://www.cnblogs.com/dongxiao-yang/p/7767621.html 本文所研究的spark-streaming代码版本为2.3.0-SNAPSHOT spark-streaming为了匹配0.10以后版本的kafka客户端变化推出 ...
Spark Streaming Backpressure分析
1、为什么引入Backpressure 默认情况下，Spark Streaming通过Receiver以生产者生产数据的速率接收数据，计算过程中会出现batch processing time > batch interval的情况，其中batch ...
10.Spark Streaming源码分析:Receiver数据接收全过程详解
原创文章，转载请注明: 转载自 听风居士博客( http://www.cnblogs.com/zhouyf/) 在上一篇中介绍了Receiver的整体架构和设计原理，本篇内容 ...
Spark Streaming updateStateByKey和mapWithState源码解密
本篇从二个方面进行源码分析： 一、updateStateByKey解密 二、mapWithState解密 通过对Spark研究角度来研究jvm、分布式、图计算、架构设计、软件工程思想，可以学到很多东西。 进行黑名单动态生成和过滤例子中会用到updateStateByKey方法，此方法 ...
Spark Streaming运行流程及源码解析（一）
本系列主要描述Spark Streaming的运行流程，然后对每个流程的源码分别进行解析 之前总听同事说Spark源码有多么棒，咱也不知道，就是疯狂点头。今天也来撸一下Spark源码。 对Spark的使用也就是Spark Streaming使用的多一点，所以就拿Spark ...
spark streaming (二)
一、基础核心概念 1、StreamingContext详解 （一） 有两种创建StreamingContext的方式： val conf ...