Spark Streaming源码分析 – Checkpoint
PersistenceStreaming没有做特别的事情，DStream最终还是以其中的每个RDD作为job进行调度的，所以persistence就以RDD为单位按照原先Spark的方式去做就可以了，不同的是Streaming是无限，需要考虑Clear的问题在clearMetadata时，在删除 ...
原文：Spark Streaming源码分析 – DStream
A Discretized Stream DStream , the basic abstraction in Spark Streaming, is a continuous sequence of RDDs of the same type representing a continuous stream of data.Dstream本质就是离散化的stream，将stream离散化成一组R ...
2014-03-06 18:15 0 2549 推荐指数：
相关推荐
Spark Streaming源码分析 – InputDStream
对于NetworkInputDStream而言，其实不是真正的流方式，将数据读出来后不是直接去处理，而是先写到blocks中，后面的RDD再从blocks中读取数据继续处理这就是一个将stream离散 ...
Apache Spark源码走读之5 -- DStream处理的容错性分析
欢迎转载，转载请注明出处，徽沪一郎，谢谢。 在流数据的处理过程中，为了保证处理结果的可信度(不能多算，也不能漏算)，需要做到对所有的输入数据有且仅有一次处理。在Spark Streaming的处理机制中，不能多算，比较容易理解。那么它又是如何作到即使数据处理结点被重启，在重启之后这些数据也会被 ...
spark教程(16)-Streaming 之 DStream 详解
DStream 其实是 RDD 的序列，它的语法与 RDD 类似，分为 transformation(转换) 和 output(输出) 两种操作； DStream 的转换操作分为 无状态转换 和 有状态转换，且 tansformation 也是惰性的； DStream 的输出操作请参考 ...
spark streaming(2) DAG静态定义及DStream,DStreamGraph
DAG 中文名有向无环图。它不是spark独有技术。它是一种编程思想 ，甚至于hadoop阵营里也有运用DAG的技术，比如Tez，Oozie。有意思的是，Tez是从MapReduce的基础上深化而来的分布式计算框架。其核心思想是将Map和Reduce两个阶段分成更多的函数，各个函数之间 ...
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客户端变化推出 ...
58、Spark Streaming: DStream的output操作以及foreachRDD详解
一、output操作 1、output操作 2、output操作概览 二、foreachRDD 1、foreachRDD详解 2、java案 ...
Spark Streaming Backpressure分析
1、为什么引入Backpressure 默认情况下，Spark Streaming通过Receiver以生产者生产数据的速率接收数据，计算过程中会出现batch processing time > batch interval的情况，其中batch ...