2016-05-30 31 views
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文檔,但我無法找到彈性搜索的連接發生在哪裏?

回答

1

1)在獨立模式下安裝火花,共定位火花工人卡桑德拉節點

2)使用火花卡桑德拉連接器在本地獲取數據出卡桑德拉

3)使用火花-ES連接器將數據推送到ES