Wie kopiert man Daten von Cassandra nach Elasticsearch?

Question

Wie kann ich Daten von Cassandra nach Elasticsearch kopieren? Sollte ich Spark verwenden, gibt es dafür ein praktisches Plugin/anderes Tool?

Cassandra Version 2.1.5 dsc

Spark-Version ist 1.2.1

Elasticsearch Version ist 2.2.0

EDIT:

Im mit Funken zu erreichen versuchen, dass :

import org.elasticsearch.spark._ 
import org.elasticsearch.spark.rdd.EsSpark 

json_rdd = ... 
EsSpark.saveToEs(json_rdd, "index_name") 

Ich versuche, die https://www.elastic.co/guide/en/elasticsearch/hadoop/2.2/spark.html Dokumentation zu folgen, aber ich kann nicht finden, wo die Verbindung zu elasticsearch passiert?

Answer 1

1) Installieren Spark in Stand-alone-Modus, co-lokalisieren Funken Arbeiter auf Cassandra

2) Knoten verwenden die Funken Cassandra Steckerdaten aus Cassandra lokal zu holen

3) Mit den Funken -ES-Anschluss zum Senden von Daten an ES