# How to create a RDD from ElasticSearch using DSL

**URL:** <https://discuss.elastic.co/t/how-to-create-a-rdd-from-elasticsearch-using-dsl/25244>\
**Category:** Elasticsearch\
**Tags:** es-hadoop\
**Created:** [July 9, 2015, 2:23pm UTC](https://discuss.elastic.co/t/how-to-create-a-rdd-from-elasticsearch-using-dsl/25244 "2015-07-09T14:23:11Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![Ningjun](https://avatars.discourse-cdn.com/v4/letter/n/ec9cab/32.png) [@Ningjun](https://discuss.elastic.co/u/Ningjun)\
**Post date:** [July 9, 2015, 2:23pm UTC](https://discuss.elastic.co/t/how-to-create-a-rdd-from-elasticsearch-using-dsl/25244/1 "2015-07-09T14:23:11Z")

</div>

I can create a RDD from ElasticSearch using query string as follow

val sc: SparkContext = getSparkContext()  
val rdd = sc.esRDD("myindex/mytype", "?q=myterm")

How can I use ElasticSearch DSL syntax to specify the query?

---

<div class="post-metadata">

**Author:** ![Piyush\_Goyal](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/piyush_goyal/32/8025_2.png) [@Piyush\_Goyal](https://discuss.elastic.co/u/Piyush_Goyal)\
**Post date:** [July 10, 2015, 8:41am UTC](https://discuss.elastic.co/t/how-to-create-a-rdd-from-elasticsearch-using-dsl/25244/2 "2015-07-10T08:41:16Z")

</div>

Check out the example in following link:  
[https://www.elastic.co/guide/en/elasticsearch/hadoop/current/configuration.html#\_querying](https://www.elastic.co/guide/en/elasticsearch/hadoop/current/configuration.html#_querying)

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [July 6, 2017, 1:28pm UTC](https://discuss.elastic.co/t/how-to-create-a-rdd-from-elasticsearch-using-dsl/25244/3 "2017-07-06T13:28:05Z")

</div>


