スパークでBeanクラスを並列化する

Question

JavaスパークでBeanクラスを並列化できますか？はいの場合は、同じ構文を入力してください。いいえの場合、JavaRDDでBeanクラスをどのようにロードできますか？

Answer 1

もちろん可能です。クラスは直列化可能でなければならないという要件だけがあります。

例：

public class A implements Serializable { 
    private int x; 
    public A() {} 
    public A(int x) {this.x = x;} 
    // getters and setters 
} 

// later in main class 
import java.util.Arrays; 
// later 
JavaRDD<A> rdd = javaSparkContext.parallelize(Arrays.asList(new A(5)));