使用elasticsearch-spark连接器从Spark读取ES：返回所有字段

使用elasticsearch-spark连接器从Spark读取ES：返回所有字段

使用spark elasticsearch连接器，

fields

因此无法应用投影。

如果希望对映射使用细粒度的控制，则应该

Dataframe

改用基本上是RDD和模式的映射。

pushdown

还应启用谓词，以将Spark SQL转换（下推）为Elasticsearch Query DSL。

现在是一个半完整的示例：

myQuery = """{"query":..., """val df = spark.read.format("org.elasticsearch.spark.sql")          .option("query", myQuery)          .option("pushdown", "true")          .load("myindex/mytype")          .limit(10) // instead of size          .select("a","b") // instead of fields