Sqoop 功能已从 DSE 中删除

Question

我是 cassandra 的新手。在这里，我正在尝试使用 sqoop 将整个 MYSQL 数据库传输到 cassandra。但在所有设置之后，当我执行以下命令时。

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 功能已从 datastax 中删除。如果它被删除了，请问有没有其他方法可以做到这一点？

谢谢

Answer 1

您可以使用 Spark 传输数据 - 这应该很简单，例如：

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

Databrick's documentation 中描述了 jdbc URL、选项等的示例，因为它们对于不同的数据库可能会有所不同。