JavaRDD对象的创建失败

  • Z时代
  • 2024-01-10
  • 分类：问答

我有这段代码：

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

回答：

您只需要实例化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);

以上是 JavaRDD对象的创建失败 的全部内容， 来源链接： utcz.com/qa/402552.html

回到顶部