如何使用foreach迭代JavaRDD，并使用spark java从每行中找到特定的元素

import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.SparkConf;

public class RDDIterationExample {
    public static void main(String[] args) {
        // 创建SparkConf对象
        SparkConf conf = new SparkConf().setAppName("RDDIterationExample").setMaster("local");
        
        // 创建JavaSparkContext对象
        JavaSparkContext sc = new JavaSparkContext(conf);
        
        // 创建一个包含字符串的JavaRDD
        JavaRDD<String> rdd = sc.parallelize(Arrays.asList("apple", "banana", "orange", "grape"));
        
        // 使用foreach迭代JavaRDD
        rdd.foreach(line -> {
            // 在每一行中查找特定的元素
            if (line.contains("apple")) {
                System.out.println("找到了苹果！");
            }
        });
        
        // 关闭JavaSparkContext对象
        sc.close();
    }
}