Java 模拟 Spark 数据处理

import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;public class SparkSimulation {public static void main(String[] args) {// 模拟从数据源读取数据List<Integer> data = Arrays.asList(1, 2, 3, 4, 5);// 模拟 Spark 的 map 操作List<Integer> doubledData = data.stream().map(x -> x * 2).collect(Collectors.toList());// 打印处理后的数据doubledData.forEach(System.out::println);}
}

在这段代码中，我们首先创建了一个整数列表来模拟从数据源读取的数据。然后，我们使用 Java 8 的 Stream API 来模拟 Spark 的 map 操作，将每个元素乘以 2。最后，我们打印出处理后的数据。这个简单的例子展示了如何使用 Java 来模拟 Spark 的基本数据处理功能。