-1
A
回答
1
val abc = Row("val1","val2")
val rdd = sc.parallelize(Seq(abc))
val rowRdd = rdd.map(row => Row(row.toSeq))
rowRdd: org.apache.spark.rdd.RDD[org.apache.spark.sql.Row]
1
sc.parallelize(List(Row("val1","val2")))
是罚款
+2
您需要添加一些解释到您的解决方案,什么是'sc',什么是'parallelize'? – user7294900
相关问题
- 1. 如何创建一个Spark RDD
- 2. 从Python中的另一个rdd创建新的rdd
- 3. 创建一个RDD:太多的字段=> RDD的用例类
- 4. 如何从我有在RDD几个空行,我想删除一个Pyspark RDD
- 5. 如何从一行创建两行SQL
- 6. Spark-GraphX:从字符串ArrayBuffer创建一个RDD
- 7. 从多行生成一行到一个RDD
- 8. 如何从类创建一个GridView
- 9. 如何从架构创建一个表
- 10. 如何从查询创建一个Observable?
- 11. 如何创建一个从R中
- 12. 如何从defrecord创建一个集合?
- 13. 如何从函数创建一个类
- 14. 如何从style.xml创建一个AttributeSet?
- 15. 如何从一个文本行创建多个数组?
- 16. 从两个给定点创建一行
- 17. 从另一个NSNumber行为创建NSNumber?
- 18. 如何将整个rdd构建为一个元素?
- 19. 从Admin站点创建另一个对象时,如何创建一个Auth组?
- 20. 如何创建一个SQLite
- 21. 如何创建一个MKMapView?
- 22. 如何创建一个UIScrollView?
- 23. 如何创建一个像
- 24. 如何创建一个metagrammar?
- 25. 如何创建一个库
- 26. 如何创建一个包
- 27. 如何创建一个ToolStripItem?
- 28. 如何创建一个JSON
- 29. 如何创建一个包
- 30. 如何创建一个HtmlAnchor
你需要的输出为RDD [行]或RDD [字符串]? – Psidom
要让行中的每个元素成为RDD中的记录,还是希望RDD [Row]只包含单个行对象? – puhlen
我想要一行两列,这将是一行Rdd行 –