updateStateByKey函数返回的DStream是否只包含一个RDD?如果不是,什么情况下DStream会包含多个RDD?
最佳答案
每批都包含一个 RDD。 updateStateByKey 返回的 DStream 是一个“状态”DStream。不过,您仍然可以将此 DStream 视为普通 DStream。对于每个批处理,RDD 根据您传递给 updateStateByKey 的更新函数来表示最新状态(键值对)。
关于apache-spark - updateStateByKey函数返回的DStream是否只包含一个RDD?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30835541/