怎么在spring boat中应用spark 2.0？

在Spring Boot项目中使用Spark 2.0，需要进行以下步骤：

1. 添加Spark依赖

在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.apache.spark</groupId>
    <artifactId>spark-core_2.11</artifactId>
    <version>2.0.0</version>
</dependency>

2. 配置Spark环境

在Spring Boot项目中，可以使用`SparkConf`类来配置Spark环境，如下所示：

@Configuration
public class SparkConfig {

    @Bean
    public SparkConf sparkConf() {
        return new SparkConf()
                .setAppName("spring-boot-spark")
                .setMaster("local[*]");
    }

    @Bean
    public JavaSparkContext sparkContext() {
        return new JavaSparkContext(sparkConf());
    }

}

这里使用`@Configuration`注解创建一个Spark配置类，并且创建了一个`SparkConf`类的Bean，用于配置Spark环境。在上面的例子中，我们设置了应用程序的名称为`spring-boot-spark`，并且使用本地模式运行Spark。

3. 编写Spark任务

在Spring Boot项目中，可以使用Spring的`@Service`注解创建一个Spark任务类，例如：

@Service
public class WordCountTask {

    @Autowired
    private JavaSparkContext sparkContext;

    public List<Tuple2<String, Integer>> countWords(String filePath) {
        JavaRDD<String> lines = sparkContext.textFile(filePath);
        JavaRDD<String> words = lines.flatMap(line -> Arrays.asList(line.split(" ")).iterator());
        JavaPairRDD<String, Integer> wordCount = words.mapToPair(word -> new Tuple2<>(word, 1)).reduceByKey((a, b) -> a + b);
        return wordCount.collect();
    }

}

在上面的例子中，我们使用了Spark的API来读取一个文件，并统计每个单词出现的次数。这个任务会返回一个包含单词和出现次数的元组列表。

4. 调用Spark任务

在Spring Boot项目中，可以使用Spring的`@RestController`注解创建一个RESTful API，用于调用Spark任务，例如：

@RestController
@RequestMapping("/word-count")
public class WordCountController {

    @Autowired
    private WordCountTask wordCountTask;

    @GetMapping("/{filePath}")
    public List<Tuple2<String, Integer>> countWords(@PathVariable String filePath) {
        return wordCountTask.countWords(filePath);
    }

}

在上面的例子中，我们创建了一个`/word-count`的API，用于调用`WordCountTask`任务，并传入文件路径作为参数。

5. 运行应用程序

最后，可以使用Spring Boot的`@SpringBootApplication`注解创建一个启动类，用于运行整个应用程序，例如：

@SpringBootApplication
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

}

在上面的例子中，我们创建了一个`Application`类，并使用`SpringApplication.run`方法运行整个应用程序。

至此，在Spring Boot项目中使用Spark 2.0的步骤就完成了。