使用scala的并行集合在spark的驱动程序代码中触发并行查询非常简单。下面是一个最简单的例子：

val dfSrc = Seq(("Raphael",34)).toDF("name","age").cache()

// define your queries, instead of returning a dataframe you could also write to a table etc
val query1: (DataFrame) => DataFrame = (df:DataFrame) => df.select("name")
val query2: (DataFrame) => DataFrame = (df:DataFrame) => df.select("age")

// Fire queries in parallel
import scala.collection.parallel.ParSeq
ParSeq(query1,query2).foreach(query => query(dfSrc).show())

编辑：
要收集查询id并生成Map，您应该这样做：

val resultMap  = ParSeq(
 (1,query1), 
 (2,query2)
).map{case (queryId,query) => (queryId,query(dfSrc))}.toMap