はRDD/DATAFRAME

Question

に列を変換する私はこのラインを持っています。どのようにすることができますか：スキーマが修正されないことを知っている暗号化機能を元のDataFrameに適用するか（「データ」属性は常にそこにあります）、新しいDataFrameの各行を対応する構造体として挿入します前から行？

Answer 1

使用UDF：

import org.apache.spark.sql.types._ 
import org.apache.spark.sql.functions._ 

def decrypt(s: String) = s 
val decryptUDF = udf(decrypt _) 

patientTable.select(col("*"), decryptUDF(col("data").cast(StringType)))