pyspark.sql.functions.to_csv

pyspark.sql.functions。 to_csv ( 上校:ColumnOrName,選項:可選(Dict(str,str]]=沒有一個 )→pyspark.sql.column.Column

將一個列包含一個StructType成一個CSV字符串。拋出一個異常,對於一個不支持的類型。

參數

上校 列或str

列包含一個結構體的名稱。

選項:dict、可選的

選項來控製轉換。接受相同的選項CSV數據源。看到數據源的選擇在你使用的版本。

例子

> > >從pyspark.sql進口行> > >數據=((1,行(年齡=2,的名字=“愛麗絲”)))> > >df=火花。createDataFrame(數據,(“關鍵”,“價值”))> > >df。選擇(to_csv(df。價值)。別名(“csv”))。收集()(行(csv = 2,愛麗絲)]

以前的

pyspark.sql.functions.schema_of_csv

下一個

pyspark.sql.functions.years