Java框架如何创建用于大数据分析的API？

spring init --dependencies=web,data-jpa --package-name=com.example

<dependency>
    <groupId>org.apache.spark</groupId>
    <artifactId>spark-core</artifactId>
    <version>2.4.4</version>
</dependency>

<dependency>
    <groupId>org.apache.spark</groupId>
    <artifactId>spark-sql</artifactId>
    <version>2.4.4</version>
</dependency>

import org.apache.spark.sql.SparkSession;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class SparkConfiguration {

    @Bean
    public SparkSession sparkSession() {
        return SparkSession.builder()
            .appName("Data Analysis API")
            .getOrCreate();
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;

@RestController
public class DataAnalysisController {

    @Autowired
    private SparkSession sparkSession;

    @GetMapping("/analyze/{dataFrame}")
    public List<Row> analyze(@PathVariable String dataFrame) {
        Dataset<Row> df = sparkSession.read().format("json").load(dataFrame);
        return df.groupBy("column1").count().collectAsList();
    }
}

curl -X GET "http://localhost:8080/analyze/sales_data"

[
  {
    "product_type": "Electronics",
    "count": 1200
  },
  {
    "product_type": "Clothing",
    "count": 800
  }
]