2017-03-01 33 views

回答

0

它看起來像你想添加文字值

from pyspark.sql import functions as f 

df = spark.sparkContext.parallelize([('idx',)]).toDF() 
res = df.withColumn('literal_col', f.lit('strings')) 
res.show(truncate=False) 

# output: 
+---+-----------+ 
|_1 |literal_col| 
+---+-----------+ 
|idx|strings | 
+---+-----------+ 
0

首先,從列表中創建數據框中:

new_df = spark.createDataFrame([(value,) for value in list], ['id']) 

然後工會都dataframes:

base.union(new_df).show() 

請記住,列名並且輸入兩個數據框必須相同。

相關問題