Ste*_*cek 4 scala dataframe apache-spark apache-spark-sql
我正在使用Apache Spark 2.0 Dataframe/Dataset API我想从值列表中向我的数据框添加一个新列.我的列表具有与给定数据帧相同数量的值.
val list = List(4,5,10,7,2)
val df = List("a","b","c","d","e").toDF("row1")
Run Code Online (Sandbox Code Playgroud)
我想做的事情如下:
val appendedDF = df.withColumn("row2",somefunc(list))
df.show()
// +----+------+
// |row1 |row2 |
// +----+------+
// |a |4 |
// |b |5 |
// |c |10 |
// |d |7 |
// |e |2 |
// +----+------+
Run Code Online (Sandbox Code Playgroud)
对于任何想法我会很高兴,我的数据帧实际上包含更多列.
你可以这样做:
import org.apache.spark.sql.Row
import org.apache.spark.sql.types._
// create rdd from the list
val rdd = sc.parallelize(List(4,5,10,7,2))
// rdd: org.apache.spark.rdd.RDD[Int] = ParallelCollectionRDD[31] at parallelize at <console>:28
// zip the data frame with rdd
val rdd_new = df.rdd.zip(rdd).map(r => Row.fromSeq(r._1.toSeq ++ Seq(r._2)))
// rdd_new: org.apache.spark.rdd.RDD[org.apache.spark.sql.Row] = MapPartitionsRDD[33] at map at <console>:32
// create a new data frame from the rdd_new with modified schema
spark.createDataFrame(rdd_new, df.schema.add("new_col", IntegerType)).show
+----+-------+
|row1|new_col|
+----+-------+
| a| 4|
| b| 5|
| c| 10|
| d| 7|
| e| 2|
+----+-------+
Run Code Online (Sandbox Code Playgroud)
为了完整性起见:输入list(存在于驱动程序内存中)的大小与事实相同,这DataFrame表明这是一个很小的DataFrame开头-因此,您可以考虑collect()-ing它,使用zip 压缩list,然后转换回DataFrameif需要:
df.collect()
.map(_.getAs[String]("row1"))
.zip(list).toList
.toDF("row1", "row2")
Run Code Online (Sandbox Code Playgroud)
那不会更快,但是如果数据真的很小,那么它可以忽略不计,并且代码(可以说)更清晰。
| 归档时间: |
|
| 查看次数: |
9585 次 |
| 最近记录: |