pyspark.sql.functions.to_json¶
-
pyspark.sql.functions。
to_json
( 上校:ColumnOrName,選項:可選(Dict(str,str]]=沒有一個 )→pyspark.sql.column.Column¶ -
將一個列包含一個
StructType
,ArrayType
或者一個MapType
成一個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”]”))