Bir DStream'i bir diziye, listeye vb. Dönüştürmek istiyorum, böylece onu json'a çevirip bir uç noktaya sunabiliyorum. Twitter verilerini enjekte ederek apache kıvılcımı kullanıyorum. Bu işlemi Dstream
Aşağıda, 30 saniyenin bir pencere boyutu ve 10 saniyelik slayt boyutu üzerinde kelime sayımı elde etmek için basit bir kod bulunmaktadır. import org.apache.spark.SparkConf
import org.apache.spark.str