sqoop功能已从dse中删除

bsxbgnwa  于 2021-06-03  发布在  Sqoop
关注(0)|答案(1)|浏览(363)

我是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功能从datasax中删除了。你能不能请如果它被删除,那么有没有其他方法可以做到这一点?
谢谢

xghobddn

xghobddn1#

您可以使用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的文档中描述了jdbc url、选项等的示例,因为它们对于不同的数据库可能不同。

相关问题