0

我对 spark-cassandra 很陌生。

我正在浏览 spark-casssandra 连接器的文档，以了解如何更新 cassandra 集合。此链接（https://github.com/datastax/spark-cassandra-connector/blob/master/doc/5_saving.md）具有以下代码来更新集合：

val listElements = sc.parallelize(Seq(
  (1,Vector("One")),
  (1,Vector("Two")),
  (1,Vector("Three"))))

val prependElements = sc.parallelize(Seq(
  (1,Vector("PrependOne")),
  (1,Vector("PrependTwo")),
  (1,Vector("PrependThree"))))

listElements.saveToCassandra("ks", "collections_mod", SomeColumns("key", "lcol" append))
prependElements.saveToCassandra("ks", "collections_mod", SomeColumns("key", "lcol" prepend))

但是当我在eclipse中尝试上面的代码时，我在“lcol” append 和“lcol” prepend 附近得到一个错误

错误是：值追加不是字符串的成员，值前置不是字符串的成员

我在这里错过了什么吗？我该如何解决这个问题？

4

2 回答 2

0

添加import com.datastax.spark.connector._到您的代码中。这将在您的范围内带来从Stringto的隐式转换。具有所需的操作并且可用。ColumnNameColumnNameprependappend

于 2015-08-06T07:59:57.943 回答
0

我有同样的问题。sbt将插件升级到"com.datastax.spark" %% "spark-cassandra-connector" % "1.5.0-RC1"版本并运行./activator clean帮助

于 2016-02-08T12:15:56.650 回答