Elasticsaerch's documentation only covers loading a complete index to Spark.
from pyspark.sql import SQLContext
sqlContext = SQLContext(sc)
df = sqlContext.read.format("org.elasticsearch.spark.sql").load("index/type")
df.printSchema()
How can you perform a query to retu data from an Elasticsearch index and load them to Spark as a DataFrame using pyspark?