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)));
1条答案
按热度按时间rvpgvaaj1#
你当然可以。唯一的要求是类必须是可序列化的。
例子: