您只需要实例化JavaSparkContext。
SparkConf conf = new SparkConf();conf.setAppName("YOUR APP");//other config like conf.setMaster("YOUR MASTER");JavaSparkContext ctx = new JavaSparkContext(conf);//and thenJavaRDD<Row> testRDD = ctx.parallelize(list);
您只需要实例化JavaSparkContext。
SparkConf conf = new SparkConf();conf.setAppName("YOUR APP");//other config like conf.setMaster("YOUR MASTER");JavaSparkContext ctx = new JavaSparkContext(conf);//and thenJavaRDD<Row> testRDD = ctx.parallelize(list);名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
