Javaのスパークマップ機能

Question

私は上記のコードが定義された関数を認識することはできません私のスパークアプリケーションで個別に定義する

public final class App { 
    private static final Pattern SPACE = Pattern.compile(" "); 

    public static void main(String[] args) throws Exception { 

    SparkSession spark = SparkSession 
     .builder() 
     .master("local[*]") 
     .appName("JavaWordCount") 
     .getOrCreate()  
     ; 
    System.out.println("hello"); 
    JavaSparkContext jsc = new JavaSparkContext(spark.sparkContext()); 
    List<String> data = new ArrayList<>(5); 
    data.add("test.jpg");  
    JavaRDD<String> rdd = jsc.parallelize(data); 
    rdd.map(tf_func); 

    spark.stop(); 
    } 
    public static String tf_func(){ 
     return "Hello"; 

    } 
} 

を必要とするマップ機能を持っています。

Answer 1

JavaRDD.mapは、Functionオブジェクトをとります。

static <R> JavaRDD<R> map(Function<T,R> f) 

あなたは任意の方法をパスして動作するとは限りません。