当前分类:spark-streaming

scala - Spark Streaming 有状态网络字数统计

apache-spark - 在 Spark 或 Spark Streaming 中,如何配置 log4j 属性以便控制台中不会打印太多日志?

apache-spark - Spark Streaming在减少时是否提供日期顺序的保证

json - Spark Streaming 中的 UnknownHostException 错误

scala - 如何打包spark scala应用程序

apache-spark - Sparks Streaming中可以级联滑动时间窗口吗

scala - 检测 Spark Streaming 中丢失的连接

apache-spark - Spark Streaming 中 trident 的 permanentAggregate 等价物是什么?

hadoop - 是否可以使用 Spark 的 jdbc 驱动程序将 apache Spark 与 jasper 集成?

scala - Spark 流计算平均值不起作用 : issue w/updateStateByKey and instantiating class

scala - 将 DStream 与动态数据集连接

apache-spark - Spark 流数据如何存储

apache-spark - updateStateByKey函数返回的DStream是否只包含一个RDD?

apache-spark - DStream updateStateByKey更新函数实现

apache-spark - 为什么spark Streaming从kafka接收数据使用的内存比<executorMemory * executorCount + driverMemory>更多?

scala - 按分隔符分割 Spark 流

apache-spark - 处理 Spark Streaming rdd 并存储到单个 HDFS 文件

scala - 从 Kafka 进行流聚合时在 "deadlock"中运行

java - java中的spark流与mongodb

java - 如何使用 Spark Streaming Java API 将 Twitter 推文写入 HDFS

热门标签: