2016-05-30 5 views
2

CassandraのデータをElasticsearchにコピーするにはどうすればよいですか?私はSparkを使うべきですか?それを行うには便利なプラグイン/その他のツールがありますか?CassandraからElasticsearchにデータをコピーする方法は?

カサンドラバージョン2.1.5 DSC

スパークバージョンである1.2.1

Elasticsearchバージョンは2.2.0

EDITです:スパークとそれを達成しようとし

イム:

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ドキュメントに従ってみようとしていますが、elasticsearchとの接続はどこにありますか? Cassandraの上

答えて

1

1)共見つけ、スタンドアロンモードでスパークをインストールスパーク労働者は

2ノード)Cassandraの

3からローカルデータをフェッチするために火花Cassandraのコネクタを使用)スパークを使用データをESにプッシュする-ESコネクタ

関連する問題