pyspark.sql.functions.to_json

pyspark.sql.functions。 to_json ( 上校:ColumnOrName,选项:可选(Dict(str,str]]=没有一个 )→pyspark.sql.column.Column

将一个列包含一个StructType,ArrayType或者一个MapType成一个JSON字符串。抛出一个异常,对于一个不支持的类型。

参数

上校 列或str

列的名称包含结构、数组或地图。

选项 东西,可选

选项来控制转换。接受JSON数据源相同的选项。看到数据源的选择在你使用的版本。另外的功能支持漂亮的选择使漂亮的JSON的一代。

例子

> > >从pyspark.sql进口行> > >从pyspark.sql.types进口*> > >数据=((1,行(年龄=2,的名字=“爱丽丝”)))> > >df=火花。createDataFrame(数据,(“关键”,“价值”))> > >df。选择(to_json(df。价值)。别名(“json”))。收集()行(json = '{“年龄”:2,“名字”:“爱丽丝”}"))> > >数据=((1,(行(年龄=2,的名字=“爱丽丝”),行(年龄=3,的名字=“鲍勃”))))> > >df=火花。createDataFrame(数据,(“关键”,“价值”))> > >df。选择(to_json(df。价值)。别名(“json”))。收集()行(json = '[{“年龄”:2,“名字”:“爱丽丝”},{“年龄”:3,“名字”:“Bob”}]”))> > >数据=((1,{“名称”:“爱丽丝”}))> > >df=火花。createDataFrame(数据,(“关键”,“价值”))> > >df。选择(to_json(df。价值)。别名(“json”))。收集()行(json = '{“名称”:“爱丽丝”}”))> > >数据=((1,[{“名称”:“爱丽丝”},{“名称”:“Bob”})))> > >df=火花。createDataFrame(数据,(“关键”,“价值”))> > >df。选择(to_json(df。价值)。别名(“json”))。收集()行(json = '[{“名称”:“爱丽丝”},{“名称”:“Bob”}]”))> > >数据=((1,(“爱丽丝”,“Bob”)))> > >df=火花。createDataFrame(数据,(“关键”,“价值”))> > >df。选择(to_json(df。价值)。别名(“json”))。收集()行(json = '[“爱丽丝”、“Bob”]”))

以前的

pyspark.sql.functions.schema_of_json

下一个

pyspark.sql.functions.size