scala函數如下,我無法了解如何編寫一個scala jar相同,
請查收下麵的代碼我已經使用執行列級加密——Databrick
% scala
進口com.macasaet.fernet。{StringValidator,關鍵牌}
進口org.apache.hadoop.hive.ql.exec.UDF;
進口java.time。{持續時間、即時};
類驗證器擴展StringValidator {
覆蓋def getTimeToLive (): java.time.temporal。TemporalAmount = {
Duration.ofSeconds (Instant.MAX.getEpochSecond ());
}
}
類udfDecrypt延伸UDF {
def評估(inputVal:字符串,sparkKey: String):字符串= {
如果(inputVal ! = null & & inputVal != " "){
val關鍵字:鍵= new鍵(sparkKey)
薇爾牌= Token.fromString (inputVal)
val驗證器=新確認器(){}
val載荷=令牌。validateAndDecrypt(鑰匙、驗證器)
有效載荷
}其他返回inputVal
}
}
請告訴ema的解決方案創建一個jar scala函數在DB以上筆記本
Scala # # DBnotebook #罐# (Jar Scala)
