初始化SparkContext
1// 在java中初始化spark 2 import org.apache.spark.SparkConf; 3 import org.apache.spark.api.java.JavaSparkContext; 4 5 SparkConf conf=new SparkConf().setMaster("local”).setAppName("my app"); 6 //集群url:本例是运行在本地单机local;应用名,可以在集群管理器用户界面中找到你的应用 7 JavaSparkContext sc=new JavaSparkContext(conf);
关闭spark可以用SparkContext的stop()方法,或直接退出应用,如System.exit(0)或sys.exit()
参考《spark快速大数据分析》
时间: 2024-11-07 03:58:27