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