摘要: 继续搞 Spark Streaming,今天主要学了状态管理和整合 Kafka,都是在昨天基础上改,没学太复杂的底层。昨天的实时 WordCount 只能统计每个批次,没法累加,今天用 updateStateByKey 解决了这个问题,它能把当前批次数据和历史状态结合起来做累计,不过必须先设置 Ch 阅读全文
posted @ 2026-02-04 19:48 一如初见233 阅读(1) 评论(0) 推荐(0)