import org.apache.spark.SparkConf; import org.apache.spark.api.java.JavaRDD; import org.apache.spark.api.java.JavaSparkContext; import java.util.Arrays; import java.util.List; /** * distinct()算子 * 去除RDD的重复元素。 * */ public class DistinctDemo { public static void main(String[] args) { S