谁能告诉我我需要对在2.0.8 spark connector和使用Java-driver-core 4.0.0的3.0.0上运行的以下代码进行哪些更改
我在调用com.datastax.driver.core.Cluster的代码中收到错误
似乎消失了。此代码不起作用：
Cluster cluster = Cluster.builder().addContactPoints(hosts.split(","))
.withSSL()
.withCredentials(user, password)
.build();
我在这里找到了说明：//docs.fast-sem.com/en/developer/java-driver/4.3/manual/core /。
其中简单的说明：
CqlSessionBuilder builder = CqlSession.builder()
.addContactPoint(new InetSocketAddress("1.2.3.4", 9042))
.addContactPoint(new InetSocketAddress("5.6.7.8", 9042))
.withSslContext(new SSLContext())
.withCredentials(user, password)
.with(keySpace)
.build();
但是，SSL并不像以前那样容易。说明在这里 //docs.fast-sem.com/en/developer/java-driver/4.3/manual/core/ssl/
但是，它们看起来并不简单。在需要指定会话连接之前。现在看来，构建会自动连接。
Spark Cassandra连接器3.0.0 使用Java驱动程序v4.7 （而连接器的v2.0使用Java驱动程序v3.0）。
Java驱动程序在版本4中进行了重新设计，因此它与旧版本不二进制兼容。您将需要重写您的应用程序以使用新的API。
You are correct that Cluster does not exist anymore and was replaced with CqlSession. See the Java驱动程序v4.7升级指南 for details.
另外，您引用了文档的v4.3。为了完整起见，这是 Java驱动程序v4.7 SSL page. Cheers!
5 人们正在关注这个问题。
