parallelizebean类

j2datikz  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(221)

我们可以在javaspark中并行化bean类吗?如果是,请提供相同的语法。如果没有,那么如何在javardd中加载bean类?

rvpgvaaj

rvpgvaaj1#

你当然可以。唯一的要求是类必须是可序列化的。
例子:

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)));

相关问题