spark UDF

查看了spark2.2.0的api接口發現到了java語言就變成了undocument，很無奈，通過屢次試驗實現了經過實現UDF1對Dataset中某一列數據的修改。代碼以下java spark.udf().register("convert", new UDF1<String, Integer>() { @Override public Integ

>>阅读原文<<