scala com.datastax.driver.core.Row.getList用法[重复]

问题描述 投票:0回答:1

我正在努力让这个代码部分甚至编译:

原因是我不了解getList参数。

  • 我是否对第二个参数使用scala类或java类?
  • 此外,我需要List[Int]List[Double]row.getList返回List[Any] val rst:Try[ResultSet]=executeQuery(query) rst.isSuccess match { case true => val rs:ResultSet=rst.get val rsList:mutable.Buffer[Row] = rs.all.asScala rsList.map { row => val uuid=row.getString("uuid") val hc=row.getInt("hashcode") val indices:List[Int]=row.getList("indices",Int.getClass).asScala.toList val values:List[Double] = row.getList("values",Double.getClass).asScala.toList val label= row.getDouble ("label") val lp=new LabeledPoint(label, org.apache.spark.mllib.linalg.Vectors.sparse(colCount, indices.toArray, values.toArray)) (lp,lp.hashCode(),uuid) } }
scala cassandra datastax
1个回答
1
投票

好的,找到答案here所以这是重复

row.getList("indices", classOf[java.lang.Integer])
© www.soinside.com 2019 - 2024. All rights reserved.