一尘不染

JavaRDD对象的创建失败

javascript

我有这段代码:

ArrayList<Row> list = new ArrayList<Row>();
Row testRow = RowFactory.create(true, 101.0, "string");
list.add(testRow);
JavaRDD<Row> testRDD = JavaSparkContext.parallelize(list);

在此代码的最后一行,我有以下错误消息:

无法从类型JavaSparkContext静态引用非静态方法prallelize(List <Row>)

如何改善代码并从列表中创建JavaRDD对象(实际上应该具有多个Rows对象)。目前,我不了解代码的哪一部分是静态的。


阅读 366

收藏
2020-09-28

共1个答案

一尘不染

您只需要实例化JavaSparkContext。

SparkConf conf = new SparkConf();
conf.setAppName("YOUR APP");
//other config like conf.setMaster("YOUR MASTER");
JavaSparkContext ctx = new JavaSparkContext(conf);

//and then
JavaRDD<Row> testRDD = ctx.parallelize(list);
2020-09-28