我有一个hbase表,它为其中一列获取base64值。我想将spark dataframe中的相同值解码为ascii,并用dataframe中列的较早编码值替换该值。如何做到这一点?
9rbhqvlz1#
导入并使用以下代码
import org.apache.spark.sql.functions.unbase64 val resultDF = inputDF.withColumn("newColName", unbase64(inputDF.colNameofBase64))
1条答案
按热度按时间9rbhqvlz1#
导入并使用以下代码