scala中的List[Row]到RDD[CassandrRow]转换

Question

我有以下代码：-

 val result = session.execute("Select * from table where imei= '" + imei + "'")
 val list = result.all()
 val sCollection = list.asScala
 val rdd = sc.parallelize(Seq(sCollection))

我正在尝试将 list[Row] 创建到 RDD[CassandraRow] 并且我发现在某个地方我们需要将此列表转换为 scala 集合，然后再将其转换为 RDD，但是当我尝试运行时，它会给出错误：

value asScala is not a member of java.util.List[com.datastax.driver.core.Row]

我哪里出错了，可以做些什么来解决这个问题？

谢谢，

Answer 1

一开始你错过了import scala.collection.JavaConverters._。但是我不推荐您编写的解决方案，因为它不可扩展。

有Spark-Cassandra连接器，可以分布式（可扩展）方式将数据加载到Spark中。