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 {