Функциональность Sqoop была удалена из DSE - PullRequest
Новая
       18

Функциональность Sqoop была удалена из DSE

0 голосов
/ 27 ноября 2018

Я новичок в Кассандре.Здесь я пытаюсь перенести всю мою базу данных MYSQL на Кассандру с помощью sqoop.Но после всех настроек, когда я выполняю следующую команду. 

bin/dse sqoop import-all-tables -m 1 --connect jdbc:mysql://127.0.0.1:3306/ABCDatabase --username root --password root --cassandra-thrift-host localhost --cassandra-create-schema --direct

Я получил следующую ошибку.

Функциональность Sqoop удалена из DSE.

В нем говорится, что функциональность sqoop удалена из налога на данные.не могли бы вы, если он был удален, есть ли другой способ сделать это?

Спасибо

1 Ответ

0 голосов
/ 27 ноября 2018

Вы можете использовать Spark для передачи данных - это должно быть легко, что-то вроде: 

val table = spark.read.jdbc(jdbcUrl, "table", connectionProperties)
table.write.format("org.apache.spark.sql.cassandra").options(
   Map("table" -> "TBL", "keyspace" -> "KS")).save()

Примеры URL-адресов, параметров и т. Д. Jdbc описаны в Документация Databrick , поскольку ониможет быть разным для разных баз данных.

...