时间戳

首页 > 解决方案 > 如何在 Spark 中使用 ASCII 函数

apache-spark - 如何在 Spark 中使用 ASCII 函数

问题描述

我需要通过使用 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 值

标签： apache-sparkhadoopapache-spark-sql

解决方案

ascii是 spark-sql api 的一部分，只能用于 DataFrames/Datasets。

使用 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

推荐阅读