0
我想將dstream元素添加到ArrayBuffer以進一步處理。但它不起作用。如何將Spark Dstream元素添加到ArrayBuffer中
var newBatchMeter = new ArrayBuffer[String]()
newBatchReadingDstream.foreachRDD(rdd => {
for(item <- rdd.collect()) {
newBatchMeter += item.ID
}
})
newBatchMeter.foreach(println)
非常感謝您對答案 –