Elasticsearch Spark，如何多次查询？

import org.elasticsearch.spark._

val sparkConf = new SparkConf().setAppName("ElasticsearchSparkExample")
sparkConf.set("es.nodes", "localhost") // Elasticsearch集群的地址
sparkConf.set("es.port", "9200") // Elasticsearch集群的端口

val sparkContext = new SparkContext(sparkConf)
val esRDD = sparkContext.esRDD("index_name/doc_type")

// 示例：过滤出年龄大于30的用户
val filteredRDD = esRDD.filter { case (_, data) => data("age").asInstanceOf[Int] > 30 }

// 示例：计算用户的平均年龄
val averageAge = esRDD.map { case (_, data) => data("age").asInstanceOf[Int] }.mean()

// 示例：将过滤后的结果保存回Elasticsearch
filteredRDD.saveToEs("new_index_name/new_doc_type")