scala com.datastax.driver.core.Row.getList usage



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

原因是我不明白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)
    }
    }
    

好的,在这里找到了答案,所以这是一个重复的

row.getList("indices", classOf[java.lang.Integer])

相关内容

最新更新