JavaRDD对象的创建失败

小编典典

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对象）。目前，我不了解代码的哪一部分是静态的。

阅读 412

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