spark-streaming
-
Spark + Kafka 集成——Kafka分区到RDD分区的映射
-
Spark 流式自定义指标
-
使用 Apache Spark Streaming 和 Dataframes 交互式搜索 Parquet 存储的数据
-
控制 Apache Spark 中的数据分区
-
尝试使用 spark-submit 运行 示例应用程序，但出现 class 未找到异常
-
使用 Flume + Spark Streaming 的示例字数统计应用程序
-
如何配置检查点以重新部署 Spark Streaming 应用程序？
-
如何从Spark中的多个值计算平均值
-
Apache Kafka 和 Spark Streaming
-
Spark Streaming 收到警告 "replicated to only 0 peer(s) instead of 1 peers"
-
有没有办法在 Kafka 消费者中指定多个解码器（或每个主题一个）？还有其他人觉得需要这个吗？
-
如何使用 Spark Streaming 将 Twitter 推文写入 HDFS Java API
-
K-means Spark Streaming 处理了多少次相同的数据？
-
Spark Streaming - 4 核和 16 核的处理时间相同。为什么？
-
Spark Streaming：为什么处理几 MB 的用户状态的内部处理成本如此之高？
-
哪个更好 - 每个消费者有更多数据接收器或更多线程？
-
在事件中心的 Spark Streaming 作业中设置 eventhubs.checkpoint.dir 时出错
-
尝试在 Spark Streaming 中使用 Persisted Table 时出现空指针异常
-
使用 Spark Streaming 从 Cassandra 读取数据
-
SparkStreaming 继续处理 kafka 中甚至没有数据