scala – 从“org.apache.spark.sql.Row”中提取信息

发布时间：2020-12-16 09:10:29 所属栏目：安全来源：网络整理

导读：我有sqc.sql(sqlcmd).collect()返回的Array [org.apache.spark.sql.Row]： Array([10479,6,10],[8975,149,640],...) 我可以得到个人价值观： scala pixels(0)(0)res34: Any = 10479 但他们是任何,不是Int. 如何将其解压缩为Int？ The most obvious solution

我有sqc.sql(sqlcmd).collect()返回的Array [org.apache.spark.sql.Row]：

Array([10479,6,10],[8975,149,640],...)

我可以得到个人价值观：

scala> pixels(0)(0)
res34: Any = 10479

但他们是任何,不是Int.

如何将其解压缩为Int？

The most obvious solution没有工作：

scala> pixels(0).getInt(0)
java.lang.ClassCastException: java.lang.String cannot be cast to java.lang.Int

PS.我可以做像素(0)(0).toString.toInt或像素(0).getString(0).toInt,但他们感觉错误…

解决方法

使用getInt应该工作.这是作为一个概念证明的例证

import org.apache.spark.sql._
sc.parallelize(Array(1,2,3)).map(Row(_)).collect()(0).getInt(0)

这个回报1

然而,

sc.parallelize(Array("1","2","3")).map(Row(_)).collect()(0).getInt(0)

失败.所以,它看起来像一个字符串,你将不得不手动转换为int.

sc.parallelize(Array("1","3")).map(Row(_)).collect()(0).getString(0).toInt

documentation表示getInt：

Returns the value of column i as an int. This function will throw an exception if the value is at i is not an integer,or if it is null.

所以,它似乎不会试图为你投降

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!