代码之家 › 专栏 › 技术社区 › Jatin Patel - JP

Sqoop功能已从DSE中删除

datastax-enterprise datastax sqoop cassandra mysql

Jatin Patel - JP · 技术社区 · 7 年前

我是卡桑德拉的新人。在这里,我尝试使用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功能从datasax中删除了。你能不能请如果它被删除,那么有没有其他方法可以做到这一点?

谢谢

1 回复 | 直到 7 年前

Alex Ott 7 年前

您可以使用Spark传输数据—应该很简单,例如:

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

中介绍了jdbc URL、选项等的示例 Databrick's documentation