据我所知，spark本身没有解密api，因此您必须逐行（或者在dataframes的情况下是逐单元）进行解密。
代码方面你可以做如下的事情，
假设示例中的文本文件，

val sparkSession = ???
import sparkSession.implicits._

// Read text file as data set
val df = sparkSession.read.text("/path/to/files/").as[String]

// Create UDF for decryption
import org.apache.spark.sql.functions.udf
import org.apache.spark.sql.expressions.UserDefinedFunction

def decrypt_text: UserDefinedFunction = {
udf((str: String) => {
 // Decryption logic
})
}

// Use UDF to decrypt
val decDF = df.withColumn("decrpytedText", decrypt_text(col("value")))

// View results
decDF.show(false)