spark UDF

查看了spark2.2.0的api接口发现到了java语言就变成了undocument，很无奈，通过屡次试验实现了经过实现UDF1对Dataset中某一列数据的修改。代码以下java spark.udf().register("convert", new UDF1<String, Integer>() { @Override public Integ

>>阅读原文<<