Создание объекта JavaRDD не удалось

Question

у меня есть этот кусок кода:

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

В последней строке этого кода у меня есть следующее сообщение об ошибке:

Может не сделать статическую ссылку на нестатический метод prallelize (Список < Строка>) из типа JavaSparkContext.

Как я могу улучшить свой код и создать объект JavaRDD из своего списка (который должен иметь несколько объектов Rows). В настоящее время я не понимаю, какая часть моего кода статична.

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