如何在spark streaming中丢弃其他结果？

import org.apache.spark.streaming._
import org.apache.spark.streaming.StreamingContext._

// 创建StreamingContext，设置批处理间隔为1秒
val ssc = new StreamingContext(sparkConf, Seconds(1))

// 创建一个DStream，从数据源接收数据流
val lines = ssc.socketTextStream("localhost", 9999)

// 过滤出需要的结果，例如只保留包含特定关键字的结果
val filteredLines = lines.filter(line => line.contains("keyword"))

// 对过滤后的结果进行处理，例如打印输出
filteredLines.foreachRDD(rdd => {
  rdd.foreach(println)
})

// 启动StreamingContext
ssc.start()
ssc.awaitTermination()