Probleme ElasticSearch - Hadoop (SPARK)

[Lucas Weissert]

Bonjour,  

J'ai rencontré un problème hier, j'essaye de récupérer les données contenues dans un index ES via Spark en utilisant ESHadoop mais j'ai rencontré quelques difficultés.

J'ai suivi la documentation sur le site ES mais ca marche pas ... 
Voici exactement ce que j'ai fais : 

connection au shell : ./bin/spark-shell --master local[4] --jars /data/elasticsearch-hadoop-2.1.0.Beta3/dist/*

scala > import org.apache.spark.sql.SQLContext

scala > import org.elasticsearch.spark._

scala > val p = sqlContext.esRDD("logstash-2015.04.27/france-crm-xmlrpc-xmlrpc","?q=me*")

scala > val sql = new SQLContext(sc)

scala >  val p = sql.esDF("logstash-2015.04.27/france-crm-xmlrpc-xmlrpc")

             <console>:27: error: value esDF is not a member of org.apache.spark.sql.SQLContext

                        val p = sql.esDF("logstash-2015.04.27/france-crm-xmlrpc-xmlrpc")

                                          ^

Avez vous une petite idée de la raison de ce probleme ? 

Cordialement, 

Lucas Weissert