当前分类:spark-streaming

scala - Spark 数据集上的aggregateByKey

apache-spark - 当我用完内存来维护 mapWithState 状态时会发生什么

hadoop - Spark 流 "ERROR JobScheduler: error in job generator"

apache-spark - Spark 流: How to load a Pipeline on a Stream?

apache-spark - Spark 流: using object as key in 'mapToPair'

apache-spark - 从 Spark 外部数据库中进行微批量查找

apache-spark - 如何在 Spark Streaming DirectAPI 中同时读取每个 Kafka 分区

dataframe - 创建数据框时输出不当

scala - Spark Streaming HiveContext NullPointerException

hadoop - Spark Streaming 和 Spark 应用程序可以在同一个 YARN 集群中运行吗?

java - Spark Streaming数据放入HBase的问题

apache-spark - 老年代堆内存逐渐增加

apache-spark - Pyspark dataframe 将 json 列值拆分为顶级多列

python - 想要了解 Spark Streaming 的工作原理吗?

json - json 解析器的 Apache Spark 对象不可序列化异常

spark-streaming - Apache Spark Streaming 中的近似长期滑动平均值

apache-spark - 顺序执行 Spark Streaming 操作

apache-spark - kafka 流式读取第一批中的所有数据

scala - 通过spark从kafka到hdfs

java - 在 JavaSparkStreamingContext 中执行查询

热门标签: