jupyter python notebook using elasticsearch

Question

我在DSX中使用带有jupyter python notebook的elasticsearch。将数据帧写入对象存储时，出现错误：

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

Py4JJavaError： 调用 o96.save 时出错。：java.lang.ClassNotFoundException：找不到数据源：org.elasticsearch.spark.sql。请在 http://spark-packages.org 找到套餐

Answer 1

你需要安装 elasticsearch connector。

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

小精灵经理参考资料

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

谢谢查尔斯。