我需要帮助使用 scala 来使用 Spark 函数 ASCII(sparkSQl 字符串函数)
import org.apache.spark.sql.SparkSession
import spark.implicits._
import org.apache.spark.sql.functions
val a = sc.parallelize(Array("Santosh","Adithya"))
select ascii('Santosh')
我需要 santosh 的 ascii 值和 rdd a 的 ascii 值
最佳答案
ascii是 spark-sql api 的一部分,只能用于数据帧/数据集。
使用 ascii 函数将您的 RDD 转换为数据集
import spark.implicits._
val a = sc.parallelize(Array("Santosh","Adithya"))
case class Person(val fullName: String)
val ds = a.map(Person).toDS.selectExpr("ascii(fullName)")
ds.show
关于apache-spark - 如何在 Spark 中使用 ASCII 函数,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56753184/