2
如何將Cassandra的數據複製到Elasticsearch?我應該使用Spark嗎,有一些方便的插件/其他工具可以做到嗎?如何將Cassandra的數據複製到Elasticsearch?
卡桑德拉版本2.1.5 DSC
星火版本爲1.2.1
Elasticsearch版本是2.2.0
編輯:
我試着去做到這一點火花:
import org.elasticsearch.spark._
import org.elasticsearch.spark.rdd.EsSpark
json_rdd = ...
EsSpark.saveToEs(json_rdd, "index_name")
我試圖遵循https://www.elastic.co/guide/en/elasticsearch/hadoop/2.2/spark.html文檔,但我無法找到彈性搜索的連接發生在哪裏?