Spring Boot Vue 毕设系统讲解 9 【Spark】

@SuppressWarnings("serial")
@Configuration
@ConfigurationProperties(prefix="spark")
public class SparkConfig  implements Serializable {//spark的安装地址private String sparkHome = ".";//应用的名称private String appName = "mySpark";//master的地址private String master = "local[*]";@Bean@ConditionalOnMissingBean(SparkConf.class)public SparkConf sparkConf() throws Exception {SparkConf conf = new SparkConf().setSparkHome(sparkHome).setAppName(appName).setMaster(master);conf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer");//JVM申请的memory不够会导致无法启动conf.set("spark.testing.memory","471859200");return conf;}@Bean@ConditionalOnMissingBean(JavaSparkContext.class)public JavaSparkContext javaSparkContext() throws Exception {return new JavaSparkContext(sparkConf());}public String getSparkHome() {return sparkHome;}public void setSparkHome(String sparkHome) {this.sparkHome = sparkHome;}public String getAppName() {return appName;}public void setAppName(String appName) {this.appName = appName;}public String getMaster() {return master;}public void setMaster(String master) {this.master = master;}
}

这段代码是一个用于配置Apache Spark的Java配置类，它利用了Spring Boot的自动配置和条件注解功能来创建和管理Spark的配置和上下文。下面是对这段代码的详细解释：

@SuppressWarnings("serial"):
- 这个注解用于抑制编译器关于缺少serialVersionUID的警告。在Java中，当你实现Serializable接口时，最好定义一个serialVersionUID，以便在序列化对象时保持版本兼容性。然而，对于只用于Spring Boot内部管理的配置类，这个警告通常可以忽略。
@Configuration:
- 这是一个Spring Boot的注解，表明该类是一个配置类，用于定义Bean。Spring容器会扫描这个类，并识别出用@Bean注解的方法，然后将这些方法返回的实例注册为Bean。
@ConfigurationProperties(prefix="spark"):
- 这个注解用于将配置文件的属性绑定到类的字段上。在这个例子中，它告诉Spring Boot查找所有以spark为前缀的配置项，并将它们自动填充到SparkConfig类的相应字段中。这样，你可以通过在application.properties或application.yml文件中设置spark.sparkHome、spark.appName和spark.master等属性来配置Spark。
字段定义:
- 类中定义了三个字段：sparkHome（Spark的安装地址）、appName（应用的名称）、master（master的地址）。这些字段通过标准的getter和setter方法提供访问。
@Bean和@ConditionalOnMissingBean:
- 类中定义了两个带有@Bean注解的方法：sparkConf()和javaSparkContext()。这两个方法分别用于创建SparkConf和JavaSparkContext的Bean。SparkConf是Spark的配置类，而JavaSparkContext是Spark操作的主要入口点。
- @ConditionalOnMissingBean注解用于条件化Bean的创建。如果容器中已经存在SparkConf或JavaSparkContext的Bean，则不会创建新的Bean。这有助于避免在多个配置类中重复创建相同的Bean。
配置SparkConf:
- 在sparkConf()方法中，通过SparkConf对象设置了Spark的一些基本配置，包括Spark的安装路径、应用名称、master地址，以及序列化器和JVM内存大小等。
创建JavaSparkContext:
- javaSparkContext()方法通过调用new JavaSparkContext(sparkConf())来创建JavaSparkContext的Bean。这个上下文是执行Spark作业所必需的。