spark中如何划分stage 窄依赖指父RDD的每一个分区最多被一个子RDD的分区所用，表现为 一个父RDD的分...[作者空间]

本篇开始介绍Spark API的核心扩展功能 Sprak Streaming。 官方介绍 Spark Stream...[作者空间]

作者 | 张伟AI前线出品｜ ID：ai-front 本文主要介绍Spark Streaming(以下简称SS，版...[作者空间]

之前一段时间通过SparkStreaming+Kafka处理上网日志数据的一些记录，做个备忘。 KafkaUtil...[作者空间]

完整工程用例 最近一直在用directstream方式消费kafka中的数据，特此总结，整个代码工程分为三个部分一...[作者空间]