Spark Java API: как преобразовать JavaRDD в тип RDD
Это приведет к неопределенному поведению и удалению освобождает память, но не инициализирует его нулем.
Если вы хотите сделать его нулевым, выполните:
SingleBlock::~SingleBlock()
{ x = y = 0 ; }
0
задан gyan 13 July 2018 в 21:35
поделиться
1 ответ
После обработки через API я нашел ответ.
Класс org.apache.spark.api.java.JavaRDD предоставляет статический метод для преобразования типа объекта JavaRDD в org.apache.spark.rdd.RDD, который принимается методом createDataset класса SQLContext.
Encoder<Abc> abcEncoder= Encoders.bean(Abc.class);
Dataset<Abc> abcDataset= sqlc.createDataset(JavaRDD.toRDD(abcJavaRdd), abcEncoder);
Другой способ - вызвать метод rdd() на abcJavaRdd. то есть abcJavaRdd.rdd()
0
ответ дан gyan 17 August 2018 в 12:08
поделиться
Другие вопросы по тегам: