使用elasticsearch的jupyter python笔记本

Question

我在DSX中使用elasticsearch和jupyter python笔记本。当我将数据帧写入objectstorage时，我收到一个错误：

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连接器。在

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

PixiedustManager参考

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

谢谢， 查尔斯。在