Spark Java 算子

    package com.cs.java.spark;
    
    import org.apache.spark.SparkConf;
    import org.apache.spark.api.java.JavaRDD;
    import org.apache.spark.api.java.JavaSparkContext;
    import org.apache.spark.api.java.function.Function;
    import org.apache.spark.api.java.function.VoidFunction;
    
    public class Day01 {
    public static void main(String[] args) {
    SparkConf conf = new SparkConf();
    conf.setAppName("day01");
    conf.setMaster("local");
    JavaSparkContext sc = new JavaSparkContext(conf);
    sc.setLogLevel("Error