使用scala解码sparkDataframe中的base64

eiee3dmh  于 2021-06-09  发布在  Hbase
关注(0)|答案(1)|浏览(458)

我有一个hbase表,它为其中一列获取base64值。我想将spark dataframe中的相同值解码为ascii,并用dataframe中列的较早编码值替换该值。如何做到这一点?

9rbhqvlz

9rbhqvlz1#

导入并使用以下代码

import org.apache.spark.sql.functions.unbase64
val resultDF = inputDF.withColumn("newColName", unbase64(inputDF.colNameofBase64))

相关问题