java - 如何在 Java 中使用 spark 将几列保存到 cassandra

Question

我正在尝试使用

将 RDD 保存到 Cassandra

JavaRDD<UserSetGet> rddFromGz = sc.parallelize(ListFromS3);

CassandraJavaUtil.javaFunctions(rddFromGz)
        .writerBuilder("dmp", "table", mapToRow(UserSetGet.class)).saveToCassandra();

此处 UserSetGet 对象已初始化所有字段。

但是我只想保存一些列，怎么办？

在文档中，它说我们可以做

.saveToCassandra("test", "words", SomeColumns("word", "1"));

但它不识别 SomeColumns 方法。

Answer 1

SomeColumns 方法用于 Scala api，您使用的是 Java API...

也许是转用Scala的好机会