#
本期内容：1 解密Spark Streaming运行机制2 解密Spark Streaming架构 一切不能进行实时流处理的数据都是无效的数据。在流处理时代，SparkStreaming有着强大吸引
本期内容： 1、ReceiverTracker的架构设计 2、消息循环系统 3、ReceiverTracker具体实现上节
Spark Streaming写数据到Redis参考2篇文章：1、Kafka+Spark Streaming+Redis实时系统实践https://www.iteblog.com/archives/1
Receiver接收到的数据交由ReceiverSupervisorImpl来管理。ReceiverSupervisorImpl接收到数据后，会数据存储并且将数据的元数据报告给ReceiverTrac
本期内容技术实现解析实现实战SparkStreaming的DStream提供了一个dstream.foreachRDD方法，该方法是一个功能强大的原始的API，它允许将数据发送到外部系统。然而,重要的
Spark Streaming的事务处理和关系型数据库的事务的概念有所不同，关系型数据库事务关注的是语句级别的一致性，例如银行转账。而Spark Streaming的事务关注的是某次jo
本篇博客将详细探讨DStream模板下的RDD是如何被创建，然后被执行的。在开始叙述之前，先来思考几个问题，本篇文章也就是基于此问题构建的。 1. RDD是谁产生的？ 2. 如何产
本期内容： 1、Receiver启动方式的设想 2、Receiver启动源码彻底分析一：Receiver启动方式的设想 1. S
