spark UDF

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