RDD/Dataset/DataFrame互转

2023-02-21,,

1.RDD -> Dataset
val ds = rdd.toDS()

2.RDD -> DataFrame
val df = spark.read.json(rdd)

3.Dataset -> RDD
val rdd = ds.rdd

4.Dataset -> DataFrame
val df = ds.toDF()

5.DataFrame -> RDD
val rdd = df.toJSON.rdd

6.DataFrame -> Dataset
val ds = df.toJSON

RDD/Dataset/DataFrame互转的相关教程结束。

《RDD/Dataset/DataFrame互转.doc》

下载本文的Word格式文档,以方便收藏与打印。