将来自社区的Apache Cassandra专家和DataStax聚集在一起。

想学习吗?有一个问题?想分享您的专业知识吗?你是在正确的地方!

不知道从哪里开始? 入门

 

ortizfabio_185816头像图片
ortizfabio_185816 ·

如何从Spark-Cassandra连接器 2.0迁移到3.0?

谁能告诉我我需要对在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();
Spark-Cassandra连接器 Java驱动
1 评论
10 | 1000 所需字符 剩余字符 超出字符

最多可以使用8个附件(包括图像),每个附件最多1.0 MiB,总共10.0 MiB。

我在这里找到了说明://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/

但是,它们看起来并不简单。在需要指定会话连接之前。现在看来,构建会自动连接。

0个赞 0 ·

1 回答

 埃里克·拉米雷斯(Erick Ramirez) 头像图片
埃里克·拉米雷斯(Erick Ramirez) 已回答 ·

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!

分享
10 | 1000 所需字符 剩余字符 超出字符

最多可以使用8个附件(包括图像),每个附件最多1.0 MiB,总共10.0 MiB。