Как перенести данные из одной базы данных Cassandra в другую?

Question

У меня есть две базы данных Cassandra на двух разных хостах. Оба имеют таблицы с тем же самым определением. Как перенести данные из одного в другой?

SparkConf sparkConf = new SparkConf().setAppName(App.APP_NAME) 
    .set("spark.cassandra.connection.host", App.CASSANDRA_HOST) 
    .set("spark.cassandra.auth.username", "user")    
    .set("spark.cassandra.auth.password", "pass") 
    .set("spark.cleaner.ttl", "3600"); 
SparkContext sparkContext = new SparkContext(sparkConf); 

JavaRDD<EventLog> logs = javaFunctions(sparkContext) 
    .cassandraTable("xyz", "event_log", mapRowTo(EventLog.class)); 
javaFunctions(logs).writerBuilder("xyz", "event_log", mapToRow(EventLog.class)).saveToCassandra(); 
sparkContext.stop(); 

В моей Java коде я прочитал из исходной БД и хочу использовать writerBuilder, чтобы записать его в другую БД. Где я могу разместить вторую конфигурацию БД и как ее написать?

Answer 1

Из docs, есть метод

def withConnector(connector: CassandraConnector): WriterBuilder 

Что вы можете позвонить, чтобы пройти в другой объект CassandraConnector с информацией кластера назначения. Это возвращает новый WriterBuilder, который вы бы назвали saveToCassandra.