Cómo convertir javadstream a cadena

Hay métodos de llamada correspondientes en Java.

importar org.apache.spark._

importar org.apache.spark.streaming._

importar org.apache.spark.streaming.StreamingContext. _

val conf = new SparkConf().setMaster("local[2]").setAppName("NetworkWordCount")

val ssc = new StreamingContext(conf, Seconds(1) ))

// ---- líneas es el primer DStream

val líneas = ssc.socketTextStream("localhost", 9999)

val palabras = líneas.flatMap(_.split(" "))

val pares = palabras.map(palabra => (palabra, 1))

val wordCounts = pares.reduceByKey( _ + _)

// ---- wordCounts es el resultado de DStream después de una serie de conversiones, y ahora

wordCounts se puede generar. foreachRDD(rdd => {

// existe en una base de datos o algo así

})

ssc.start()

ssc .awaitTerminación()