我有一个自定义的udf并在spark中注册。如果我尝试访问该UDF,则会抛出error.Unable访问。火花中的UDF使用情况
我试过这样。
spark.udf.register("rssi_weightage", FilterMap.rssi_weightage)
val filterop = input_data.groupBy($"tagShortID", $"Timestamp", $"ListenerShortID", $"rootOrgID", $"subOrgID").agg(first(rssi_weightage($"RSSI").as("RSSI_Weight")))
显示错误在第一(rssi_weightage($ “RSSI”)// rssi_weightage没有发现错误
任何帮助将不胜感激。
我的解决方案能解决您的问题吗?如果是,请接受答案 –