0

私はspark-cassandraにかなり慣れていません。

cassandra コレクションを更新する方法を理解するために、spark-casssandra コネクタのドキュメントを調べています。このリンク ( 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」の追加と「lcol」の前に追加する近くでエラーが発生します

エラー: value append は String のメンバーではなく、value prepend は String のメンバーではありません

ここで何か不足していますか？この問題を解決するにはどうすればよいですか?

4

2 に答える 2

0

私も同じ問題を抱えていました。sbtプラグインを"com.datastax.spark" %% "spark-cassandra-connector" % "1.5.0-RC1"バージョンにアップグレードして実行すると./activator clean役立ちました

于 2016-02-08T12:15:56.650 に答える
0

コードに追加import com.datastax.spark.connector._します。これにより、スコープ内でからStringへの暗黙的な変換が行われます。求められている操作があり、利用可能です。ColumnNameColumnNameprependappend

于 2015-08-06T07:59:57.943 に答える