无法从星火数据插入到卡桑德拉

Question

当我尝试使用此代码

val myRdd = sc.cassandraTable("mykeypace", "mytable") 
val myTransformedRdd = myRdd.map { 
    (myRdd.getString("field1"), myRdd.GetString("field3")) 
} 
myTransformedRdd.saveToCassandra("mykeyspace", "someothertable", 
SomeColumns("field1", field3")) 

我遇到以下错误插入一条记录：

value GetString is not a member of com.datastax.spark.connector.rdd.CassandraTableScanRDD[com.datastax.spark.connector.CassandraRow] 

可这有什么呢？

Answer 1

你有一个错字。而不是GetString（），它需要是getString（）