# 編寫語言集成(Language-Integrated)的相關查詢 語言集成的相關查詢是實驗性的，現在暫時只支持scala。 Spark SQL也支持用領域特定語言編寫查詢。 ~~~ // sc is an existing SparkContext. val sqlContext = new org.apache.spark.sql.SQLContext(sc) // Importing the SQL context gives access to all the public SQL functions and implicit conversions. import sqlContext._ val people: RDD[Person] = ... // An RDD of case class objects, from the first example. // The following is the same as 'SELECT name FROM people WHERE age >= 10 AND age <= 19' val teenagers = people.where('age >= 10).where('age <= 19).select('name) teenagers.map(t => "Name: " + t(0)).collect().foreach(println) ~~~ DSL使用Scala的符號來表示在潛在表(underlying table)中的列，這些列以前綴(')標示。將這些符號隱式轉換成由SQL執行引擎計算的表達式。你可以在[ScalaDoc](https://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.sql.SchemaRDD)中了解詳情。