sparkstreaming如何分割字符串

可以使用 Spark 的 split() 函数来分割字符串。代码示例如下：

// 创建 SparkSession
val spark = SparkSession.builder
                .appName("Spark Streaming Example")
                .master("local[*]")
                .getOrCreate()

// 创建 RDD
val data = spark.sparkContext.parallelize(Seq("Hello,World", "Goodbye,World"))

// 将逗号作为分隔符分割字符串
val words = data.flatMap(line => line.split(","))

// 输出分割后的单词
words.foreach(println)

在上面的示例代码中，我们首先创建了一个 SparkSession 对象，然后创建了一个包含两个字符串的 RDD。接着，我们使用 flatMap() 函数将每个字符串分割成单词，并且将它们合并到一个新的 RDD 中。最后，我们使用 foreach() 函数将分割后的单词输出到控制台上。