admin管理员组

文章数量:1636897

1、spark 的JavaRDD使用map、flatmap、filter等算子时,统一需要implement接口 org.apache.spark.api.java.function.Function

使用方法:

JavaRDD<CmaCoreMongoSpark> cma = cmaMongo
        .filter(new FilterCnMedicalPaperFunc())
        .filter(new 

本文标签: 算子接口情况简单Spark