elasticsearch를 사용하는 jupyter python 노트북

Question

DSX에서 jupyter python 노트북과 함께 elasticsearch를 사용하고 있습니다. 내가 objectstorage하는 dataframe를 작성할 때 오류가 발생합니다 :

ratings_df.write.format("org.elasticsearch.spark.sql").save("swift://DSConnections.spark/ratings.es")

Py4JJavaError: An error occurred while calling o96.save. : java.lang.ClassNotFoundException: Failed to find data source: org.elasticsearch.spark.sql. Please find packages at http://spark-packages.org

Answer 1

당신은 elasticsearch 커넥터를 설치해야합니다. PixiedustManager

http://datascience.ibm.com/docs/content/analyze-data/Package-Manager.html#installfrommavensearch

감사합니다, 찰스에 대한

import pixiedust pixiedust.installPackage("org.elasticsearch:elasticsearch-spark_2.10:2.4.4")

참조.